From 75a2ffab674f3492adda5586f3415e812a09035c Mon Sep 17 00:00:00 2001
From: Adam Libresco <alibresco@gmail.com>
Date: Wed, 20 Dec 2023 09:05:19 -0500
Subject: [PATCH] Only fetch kafka metadata for relevant topics

---
 pkg/outputs/kafka_output/kafka_output.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/outputs/kafka_output/kafka_output.go b/pkg/outputs/kafka_output/kafka_output.go
index 17ff1977..6de2ce4d 100644
--- 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":