disbale reset kafka connection timeout

Signed-off-by: Enwei Jiao <[email protected]>
jiaoew1991 · Nov 23, 2023 · 8b73873 · 8b73873
1 parent a04b528
commit 8b73873
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go b/pkg/mq/msgstream/mqwrapper/kafka/kafka_client.go
@@ -59,13 +59,13 @@ func NewKafkaClientInstanceWithConfigMap(config kafka.ConfigMap, extraConsumerCo
 func NewKafkaClientInstanceWithConfig(ctx context.Context, config *paramtable.KafkaConfig) (*kafkaClient, error) {
 	kafkaConfig := getBasicConfig(config.Address.GetValue())
 
-	// connection setup timeout, default as 30000ms
+	// connection setup timeout, default as 30000ms, available range is [1000, 2147483647]
 	if deadline, ok := ctx.Deadline(); ok {
 		if deadline.Before(time.Now()) {
 			return nil, errors.New("context timeout when new kafka client")
 		}
-		timeout := time.Until(deadline).Milliseconds()
-		kafkaConfig.SetKey("socket.connection.setup.timeout.ms", timeout)
+		// timeout := time.Until(deadline).Milliseconds()
+		// kafkaConfig.SetKey("socket.connection.setup.timeout.ms", timeout)
 	}
 
 	if (config.SaslUsername.GetValue() == "" && config.SaslPassword.GetValue() != "") ||