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

Method PauseAll

consumer.go:92–92  ·  view source on GitHub ↗

PauseAll suspends fetching from all partitions. Future calls to the broker will not return any records from these partitions until they have been resumed using Resume()/ResumeAll(). Note that this method does not affect partition subscription. In particular, it does not cause a group rebalance when

()

Source from the content-addressed store, hash-verified

90 // Note that this method does not affect partition subscription.
91 // In particular, it does not cause a group rebalance when automatic assignment is used.
92 PauseAll()
93
94 // ResumeAll resumes all partitions which have been paused with Pause()/PauseAll().
95 // New calls to the broker will return records from these partitions if there are any to be fetched.

Callers 2

toggleConsumptionFlowFunction · 0.65
toggleConsumptionFlowFunction · 0.65

Implementers 2

consumerconsumer.go
Consumermocks/consumer.go

Calls

no outgoing calls

Tested by

no test coverage detected