From d9aaefd469ca2f49adda55ae79eca0d647055286 Mon Sep 17 00:00:00 2001 From: Sedky Date: Fri, 8 Sep 2023 16:42:42 +0200 Subject: [PATCH] Remove async option --- pumps/kafka.go | 1 - 1 file changed, 1 deletion(-) diff --git a/pumps/kafka.go b/pumps/kafka.go index 44143ec8d..a40085353 100644 --- a/pumps/kafka.go +++ b/pumps/kafka.go @@ -172,7 +172,6 @@ func (k *KafkaPump) Init(config interface{}) error { k.writerConfig.BatchBytes = k.kafkaConf.BatchBytes // 100 MB k.writerConfig.BatchSize = k.kafkaConf.BatchSize //100K k.writerConfig.BatchTimeout = time.Duration(k.kafkaConf.BatchTimeout) // every second - k.writerConfig.Async = true if k.kafkaConf.Compressed { k.writerConfig.CompressionCodec = snappy.NewCompressionCodec()