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()