From 8234f6dc6d3f989a27454829b41939d784b4c382 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 4698e788..51581184 100644
--- a/internal/endpoint/kafka.go
+++ b/internal/endpoint/kafka.go
@@ -66,7 +66,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")