diff --git a/consumergroup.go b/consumergroup.go index 64fb3293a..0c9843a45 100644 --- a/consumergroup.go +++ b/consumergroup.go @@ -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 {