diff --git a/pkg/kafkax/kafka.go b/pkg/kafkax/kafka.go
index f6c40aa..58794b2 100644
--- 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