From 68c03311abd022957b0f1e91b72d69864b1d7793 Mon Sep 17 00:00:00 2001 From: Mihai Todor Date: Tue, 27 Aug 2024 01:10:36 +0100 Subject: [PATCH] Fix typo in kgo.Client.ResumeFetchTopics() docs Signed-off-by: Mihai Todor --- pkg/kgo/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/kgo/consumer.go b/pkg/kgo/consumer.go index 01f98da4..8b2b2318 100644 --- a/pkg/kgo/consumer.go +++ b/pkg/kgo/consumer.go @@ -620,7 +620,7 @@ func (cl *Client) PauseFetchPartitions(topicPartitions map[string][]int32) map[s // ResumeFetchTopics resumes fetching the input topics if they were previously // paused. Resuming topics that are not currently paused is a per-topic no-op. -// See the documentation on PauseTfetchTopics for more details. +// See the documentation on PauseFetchTopics for more details. func (cl *Client) ResumeFetchTopics(topics ...string) { defer cl.allSinksAndSources(func(sns sinkAndSource) { sns.source.maybeConsume()