fix: clientId

xinpianchang · Oct 29, 2021 · 08d2582 · 08d2582
1 parent 3439b9f
commit 08d2582
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kafkax/kafka.go b/pkg/kafkax/kafka.go
@@ -90,7 +90,7 @@ func New(name string, cfg ...*sarama.Config) (Client, error) {
 	if hostname == "" {
 		hostname = netx.InternalIp()
 	}
-	config.ClientID = fmt.Sprint("sarama", "/", hostname, "/", os.Getpid())
+	config.ClientID = fmt.Sprint("sarama", "_", hostname, "_", os.Getpid())
 
 	config.Consumer.Return.Errors = true
 	config.Producer.Return.Successes = true