Method RefreshCoordinator

client.go:99–99

RefreshCoordinator retrieves the coordinator for a consumer group and stores it in local cache. This function only works on Kafka 0.8.2 and higher.

(consumerGroup string)

	// RefreshCoordinator retrieves the coordinator for a consumer group and stores it
	// in local cache. This function only works on Kafka 0.8.2 and higher.
	RefreshCoordinator(consumerGroup string) error

	// TransactionCoordinator returns the coordinating broker for a transaction id. It will
	// return a locally cached value if it's available. You can call