feat: WithClientInfo added for client_id

Signed-off-by: Eray Ates <[email protected]>

clientoptions.go

@@ -9,6 +9,7 @@ import (
 type options struct {
 	Consumer          consumer
 	ClientID          string
+	InfoVersion       string
 	KGOOptions        []kgo.Opt
 	AutoTopicCreation bool
 }
@@ -25,6 +26,15 @@ func WithClientID(clientID string) Option {
 	}
 }
 
+// WithClientInfo to set client_id in kafka server.
+// Not usable with WithClientID option.
+//   - appname:version@hostname
+func WithClientInfo(name, version string) Option {
+	return func(o *options) {
+		o.ClientID = name + ":" + version + "@" + idHostname
+	}
+}
+
 // WithAutoTopicCreation to enable auto topic creation for producer and consumer.
 //
 // Default is enabled.

example/consume/main.go

@@ -14,7 +14,7 @@ import (
 
 var (
 	kafkaConfig = wkafka.Config{
-		Brokers: []string{"localhost:9095"},
+		Brokers: []string{"localhost:9092"},
 	}
 	consumeConfig = wkafka.ConsumeConfig{
 		Topics:     []string{"test"},
@@ -67,7 +67,11 @@ func main() {
 
 func run(ctx context.Context, _ *sync.WaitGroup) error {
 	p := Processor{}
-	client, err := wkafka.NewClient(ctx, kafkaConfig, wkafka.WithConsumerBatch(consumeConfig, p))
+	client, err := wkafka.NewClient(
+		ctx, kafkaConfig,
+		wkafka.WithConsumerBatch(consumeConfig, p),
+		wkafka.WithClientInfo("testapp", "v0.1.0"),
+	)
 	if err != nil {
 		return err
 	}

id.go

@@ -6,11 +6,15 @@ import (
 	"path/filepath"
 )
 
-var DefaultClientID string
+var (
+	DefaultClientID string
+	idProgname      string
+	idHostname      string
+)
 
 func init() {
-	progname := filepath.Base(os.Args[0])
-	hostname, _ := os.Hostname()
+	idProgname = filepath.Base(os.Args[0])
+	idHostname, _ = os.Hostname()
 
-	DefaultClientID = fmt.Sprintf("%s@%s", progname, hostname)
+	DefaultClientID = fmt.Sprintf("%s@%s", idProgname, idHostname)
 }