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

Method Controller

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

Controller returns the cluster controller broker. It will return a locally cached value if it's available.

()

Source from the content-addressed store, hash-verified

191 // Controller returns the cluster controller broker. It will return a
192 // locally cached value if it's available.
193 Controller() (*Broker, error)
194
195 // Coordinator returns the coordinating broker for a consumer group. It will
196 // return a locally cached value if it's available.

Implementers 1

clusterAdminadmin.go

Calls

no outgoing calls