From 9fdc0d0fbc305735060a0ac53ce67a91f90d7d9b Mon Sep 17 00:00:00 2001 From: nap_all_day <44193366+napallday@users.noreply.github.com> Date: Tue, 25 Jul 2023 15:43:00 +0800 Subject: [PATCH] fix: comments for PauseAll and ResumeAll (#2523) Signed-off-by: napallday Signed-off-by: Ioan Zicu --- consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consumer.go b/consumer.go index eb27df8d73..4d08b3ddae 100644 --- a/consumer.go +++ b/consumer.go @@ -85,13 +85,13 @@ type Consumer interface { // New calls to the broker will return records from these partitions if there are any to be fetched. Resume(topicPartitions map[string][]int32) - // Pause suspends fetching from all partitions. Future calls to the broker will not return any + // 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 automatic assignment is used. PauseAll() - // Resume resumes all partitions which have been paused with Pause()/PauseAll(). + // ResumeAll resumes all 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. ResumeAll() }