From 6dfcf896d494ab55049a9c58716d85b8390791c5 Mon Sep 17 00:00:00 2001 From: Benjamin Ramser Date: Thu, 8 Jul 2021 12:26:58 +0200 Subject: [PATCH] Leave ClientID default untouched --- internal/endpoint/kafka.go | 1 - 1 file changed, 1 deletion(-) diff --git a/internal/endpoint/kafka.go b/internal/endpoint/kafka.go index a7e11f3c..77cf0348 100644 --- a/internal/endpoint/kafka.go +++ b/internal/endpoint/kafka.go @@ -80,7 +80,6 @@ func (conn *KafkaConn) Send(msg string) error { if conn.ep.Kafka.SASL { log.Debugf("building kafka sasl config") - cfg.ClientID = "sasl_scram_client" cfg.Net.SASL.Enable = true cfg.Net.SASL.User = os.Getenv("KAFKA_USERNAME") cfg.Net.SASL.Password = os.Getenv("KAFKA_PASSWORD")