Fix Kafka initialization crash (#16523)

2023-02-02 14:51:19 +01:00
parent 2278fc8f47
commit 0b7989aa4b
1 changed files with 0 additions and 1 deletions
--- 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