Remove async option

TykTechnologies · Sep 8, 2023 · d9aaefd · d9aaefd
1 parent d83714c
commit d9aaefd
Showing 1 changed file with 0 additions and 1 deletion.
diff --git 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()