Skip to content

Commit

Permalink
Merge pull request #812 from mihaitodor/fix-doc-typo
Browse files Browse the repository at this point in the history
Fix typo in kgo.Client.ResumeFetchTopics() docs
  • Loading branch information
twmb authored Oct 8, 2024
2 parents 79895a9 + 68c0331 commit 1fdc835
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/kgo/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit 1fdc835

Please sign in to comment.