Fix kafka config type error

Signed-off-by: Enwei Jiao <[email protected]>
jiaoew1991 · Nov 22, 2023 · 650cdcd · 650cdcd
1 parent e8c5e75
commit 650cdcd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go b/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go
@@ -65,7 +65,7 @@ func NewKafkaClientInstanceWithConfig(ctx context.Context, config *paramtable.Ka
 			return nil, errors.New("context timeout when new kafka client")
 		}
 		timeout := time.Until(deadline).Milliseconds()
-		kafkaConfig.SetKey("socket.connection.setup.timeout.ms", timeout)
+		kafkaConfig.SetKey("socket.connection.setup.timeout.ms", strconv.FormatInt(timeout, 10))
 	}
 
 	if (config.SaslUsername.GetValue() == "" && config.SaslPassword.GetValue() != "") ||