Method Pause

consumer.go:82–82

Pause suspends fetching from the requested 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 rebalanc

(topicPartitions map[string][]int32)

	// Note that this method does not affect partition subscription.
	// In particular, it does not cause a group rebalance when automatic assignment is used.
	Pause(topicPartitions map[string][]int32)

	// Resume resumes specified partitions which have been paused with Pause()/PauseAll().
	// New calls to the broker will return records from these partitions if there are any to be fetched.