From d7c0c5b8551e323619aea7126578e339adf057a7 Mon Sep 17 00:00:00 2001
From: Benjamin Ramser <legionaerr@googlemail.com>
Date: Thu, 18 Feb 2021 22:35:49 +0100
Subject: [PATCH] refactor: dont set client id

---
 internal/endpoint/kafka.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/internal/endpoint/kafka.go b/internal/endpoint/kafka.go
index 9f0e1df2..310a0194 100644
--- a/internal/endpoint/kafka.go
+++ b/internal/endpoint/kafka.go
@@ -67,7 +67,6 @@ func (conn *KafkaConn) Send(msg string) error {
 	uri := fmt.Sprintf("%s:%d", conn.ep.Kafka.Host, conn.ep.Kafka.Port)
 	if conn.conn == nil {
 		cfg := sarama.NewConfig()
-		cfg.ClientID = "Tile38" // otherwise defaults to sarama
 
 		if conn.ep.Kafka.TLS {
 			log.Debugf("building kafka tls config")