From 650cdcd2e0abe6cba25c3b36d38e923a14912734 Mon Sep 17 00:00:00 2001 From: Enwei Jiao Date: Wed, 22 Nov 2023 11:35:11 +0800 Subject: [PATCH] Fix kafka config type error Signed-off-by: Enwei Jiao --- pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go b/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go index d8e45bdcbb0f3..69a3e57344aa0 100644 --- 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() != "") ||