diff --git a/common/kafka/config.go b/common/kafka/config.go
index 2ce0f89c..89816955 100644
--- a/common/kafka/config.go
+++ b/common/kafka/config.go
@@ -9,6 +9,7 @@ import (
 	"crypto/sha256"
 	"crypto/sha512"
 	"errors"
+	"fmt"
 
 	"akvorado/common/helpers"
 	"akvorado/common/helpers/bimap"
@@ -127,6 +128,7 @@ func (sa *SASLMechanism) UnmarshalText(input []byte) error {
 func NewConfig(config Configuration) (*sarama.Config, error) {
 	kafkaConfig := sarama.NewConfig()
 	kafkaConfig.Version = sarama.KafkaVersion(config.Version)
+	kafkaConfig.ClientID = fmt.Sprintf("akvorado-%s", helpers.AkvoradoVersion)
 	tlsConfig, err := config.TLS.TLSConfiguration.MakeTLSConfig()
 	if err != nil {
 		return nil, err