Skip to content

Commit

Permalink
remove outdated comment
Browse files Browse the repository at this point in the history
  • Loading branch information
rhansen2 committed Sep 10, 2022
1 parent 3affcef commit 74ce616
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions consumergroup.go
Original file line number Diff line number Diff line change
Expand Up @@ -612,12 +612,7 @@ func (t *timeoutCoordinator) readPartitions(ctx context.Context, topics ...strin
ctx, cancel := context.WithTimeout(ctx, t.timeout)
defer cancel()
metaResp, err := t.client.Metadata(ctx, &MetadataRequest{
Topics: topics,
// With this set to false the consumer group gets caught
// looping getting unknown topic or partition errors.
// This is the same behavior as the Java Consumer
// which always sends the metadata request with auto topic
// creation set to true.
Topics: topics,
AllowAutoTopicCreation: t.autoCreateTopic,
})
if err != nil {
Expand Down

0 comments on commit 74ce616

Please sign in to comment.