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

Method LeaderAndEpoch

client.go:61–61  ·  view source on GitHub ↗

LeaderAndEpoch returns the leader and its epoch for the current topic/partition, as determined by querying the cluster metadata.

(topic string, partitionID int32)

Source from the content-addressed store, hash-verified

59 // LeaderAndEpoch returns the leader and its epoch for the current
60 // topic/partition, as determined by querying the cluster metadata.
61 LeaderAndEpoch(topic string, partitionID int32) (*Broker, int32, error)
62
63 // Replicas returns the set of all replica IDs for the given partition.
64 Replicas(topic string, partitionID int32) ([]int32, error)

Callers 3

ConsumePartitionMethod · 0.65
preferredBrokerMethod · 0.65
ListOffsetsMethod · 0.65

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by

no test coverage detected