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

Method OfflineReplicas

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

OfflineReplicas returns the set of all offline replica IDs for the given partition. Offline replicas are replicas which are offline

(topic string, partitionID int32)

Source from the content-addressed store, hash-verified

71 // OfflineReplicas returns the set of all offline replica IDs for the given
72 // partition. Offline replicas are replicas which are offline
73 OfflineReplicas(topic string, partitionID int32) ([]int32, error)
74
75 // RefreshBrokers takes a list of addresses to be used as seed brokers.
76 // Existing broker connections are closed and the updated list of seed brokers

Callers 1

Implementers 2

stubLeaderClientasync_producer_test.go
clientclient.go

Calls

no outgoing calls

Tested by 1