Fix kafka client hang after killing broker pod of parition leader (#1…

…6983) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>
milvus-io · May 14, 2022 · 328ab7e · 328ab7e
1 parent 23f7ef9
commit 328ab7e
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/internal/mq/msgstream/mqwrapper/kafka/kafka_client.go b/internal/mq/msgstream/mqwrapper/kafka/kafka_client.go
@@ -58,8 +58,6 @@ func (kc *kafkaClient) newProducerConfig() *kafka.ConfigMap {
 	// default max message size 5M
 	newConf.SetKey("message.max.bytes", 10485760)
 	newConf.SetKey("compression.codec", "zstd")
-	newConf.SetKey("go.events.channel.size", 0)
-	newConf.SetKey("go.produce.channel.size", 0)
 	newConf.SetKey("linger.ms", 20)
 	return newConf
 }