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
()
| 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. |
no outgoing calls
no test coverage detected