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

Method RequiresConsistency

partitioner.go:23–23  ·  view source on GitHub ↗

RequiresConsistency indicates to the user of the partitioner whether the mapping of key->partition is consistent or not. Specifically, if a partitioner requires consistency then it must be allowed to choose from all partitions (even ones known to be unavailable), and its choice must be respected by

()

Source from the content-addressed store, hash-verified

21 // partitions (even ones known to be unavailable), and its choice must be
22 // respected by the caller. The obvious example is the HashPartitioner.
23 RequiresConsistency() bool
24}
25
26// DynamicConsistencyPartitioner can optionally be implemented by Partitioners

Callers 1

partitionMessageMethod · 0.65

Implementers 6

manualPartitionerpartitioner.go
randomPartitionerpartitioner.go
roundRobinPartitionerpartitioner.go
hashPartitionerpartitioner.go
murmur2Partitionerpartitioner.go
brokePartitionermocks/async_producer_test.go

Calls

no outgoing calls

Tested by

no test coverage detected