View definition

(Client).Coordinator

Defined in github.com/Shopify/sarama/client.go

Description

Coordinator returns the coordinating broker for a consumer group. It will return a locally cached value if it's available. You can call RefreshCoordinator to update the cached value. This function only works on Kafka 0.8.2 and higher.

Coordinator is referenced in 8 repositories

github.com/Shopify/sarama gopkg.in/bsm/sarama-cluster.v2 github.com/bsm/sarama-cluster

...