Remove other uses of AllowAutoTopicCreation

Signed-off-by: Dimitar Dimitrov <dimitar.dimitrov@grafana.com>

Makefile

@@ -482,7 +482,7 @@ lint: check-makefiles
 	# As a result the topic can be created with the wrong number of partitions.
 	faillint -paths \
 		"github.com/twmb/franz-go/pkg/kgo.{AllowAutoTopicCreation}" \
-		./pkg/... ./cmd/... ./integration/...
+		./pkg/... ./cmd/... ./tools/... ./integration/...
 
 format: ## Run gofmt and goimports.
 	find . $(DONT_FIND) -name '*.pb.go' -prune -o -type f -name '*.go' -exec gofmt -w -s {} \;

pkg/blockbuilder/kafkautil_test.go

@@ -146,7 +146,6 @@ func TestKafkaMarshallingCommitMeta(t *testing.T) {
 func mustKafkaClient(t *testing.T, addrs ...string) *kgo.Client {
 	writeClient, err := kgo.NewClient(
 		kgo.SeedBrokers(addrs...),
-		kgo.AllowAutoTopicCreation(),
 		// We will choose the partition of each record.
 		kgo.RecordPartitioner(kgo.ManualPartitioner()),
 	)

pkg/blockbuilder/scheduler/scheduler_test.go

@@ -25,7 +25,6 @@ import (
 func mustKafkaClient(t *testing.T, addrs ...string) *kgo.Client {
 	writeClient, err := kgo.NewClient(
 		kgo.SeedBrokers(addrs...),
-		kgo.AllowAutoTopicCreation(),
 		// We will choose the partition of each record.
 		kgo.RecordPartitioner(kgo.ManualPartitioner()),
 	)

tools/kafkatool/util.go

@@ -16,7 +16,6 @@ func CreateKafkaClient(kafkaAddress, kafkaClientID string, auth sasl.Mechanism)
 		kgo.ClientID(kafkaClientID),
 		kgo.RecordPartitioner(kgo.ManualPartitioner()),
 		kgo.DisableIdempotentWrite(),
-		kgo.AllowAutoTopicCreation(),
 		kgo.BrokerMaxWriteBytes(268_435_456),
 		kgo.MaxBufferedBytes(268_435_456),
 	}