|
|
broker, err := client.Coordinator(fmt.Sprintf("another_new_consumer_group_%d", i))
|
|
broker, err := client.Coordinator(fmt.Sprintf("another_new_consumer_group_%d", i))
|
|
|
if connected, err := broker.Connected(); !connected || err != nil {
|
|
if connected, err := broker.Connected(); !connected || err != nil {
|