MCPcopy
hub / github.com/IBM/sarama / Coordinator

Method Coordinator

admin.go:197–197  ·  view source on GitHub ↗

Coordinator returns the coordinating broker for a consumer group. It will return a locally cached value if it's available.

(group string)

Source from the content-addressed store, hash-verified

195 // Coordinator returns the coordinating broker for a consumer group. It will
196 // return a locally cached value if it's available.
197 Coordinator(group string) (*Broker, error)
198
199 // Remove members from the consumer group by given member identities.
200 // This operation is supported by brokers with version 2.3 or higher

Callers 7

CoordinatorMethod · 0.65
DeleteConsumerGroupMethod · 0.65

Implementers 1

clusterAdminadmin.go

Calls

no outgoing calls

Tested by

no test coverage detected