From 0b7989aa4b4746ffc43c15b5fab19ee4c753cb57 Mon Sep 17 00:00:00 2001 From: Klaus Post Date: Thu, 2 Feb 2023 14:51:19 +0100 Subject: [PATCH] Fix Kafka initialization crash (#16523) --- internal/event/target/kafka.go | 1 - 1 file changed, 1 deletion(-) diff --git a/internal/event/target/kafka.go b/internal/event/target/kafka.go index 4e181b68f..de2483f75 100644 --- a/internal/event/target/kafka.go +++ b/internal/event/target/kafka.go @@ -321,7 +321,6 @@ func (target *KafkaTarget) initKafka() error { if err != sarama.ErrOutOfBrokers { target.loggerOnce(context.Background(), err, target.ID().String()) } - target.producer.Close() return err } target.producer = producer