Only fetch kafka metadata for relevant topics

openconfig · Dec 20, 2023 · 75a2ffa · 75a2ffa
1 parent edb9f72
commit 75a2ffa
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":