Merge pull request #324 from alibresco/main

Only fetch kafka metadata for relevant topics
openconfig · Dec 20, 2023 · 0bba558 · 0bba558
2 parents e3632a8 + 75a2ffa
commit 0bba558
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/outputs/kafka_output/kafka_output.go b/pkg/outputs/kafka_output/kafka_output.go
@@ -419,6 +419,7 @@ func (k *kafkaOutput) createConfig() (*sarama.Config, error) {
 	cfg.Producer.RequiredAcks = sarama.WaitForAll
 	cfg.Producer.Return.Successes = true
 	cfg.Producer.Timeout = k.Cfg.Timeout
+	cfg.Metadata.Full = false
 
 	switch k.Cfg.CompressionCodec {
 	case "gzip":