johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-11 22:14:02 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

common/kafka: set Kafka ClientID to akvorado instead of sarama

Browse Source
This commit is contained in:
Vincent Bernat
2024-07-21 16:18:01 +02:00
parent c985733265
commit 102cd7fe9c
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
common/kafka/config.go
View File

@@ -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