From 69df50fe170f023ebc565186c72a2673fdab2b64 Mon Sep 17 00:00:00 2001
From: agapple <jianghang115@gmail.com>
Date: Mon, 8 Apr 2019 19:57:00 +0800
Subject: [PATCH] fixed issue #1672 , CanalKafkaProducer send

---
 .../com/alibaba/otter/canal/kafka/CanalKafkaProducer.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaProducer.java b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaProducer.java
index 6cc6724f..faac1cfc 100644
--- a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaProducer.java
+++ b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaProducer.java
@@ -203,9 +203,9 @@ public class CanalKafkaProducer implements CanalMQProducer {
             null,
             JSON.toJSONString(flatMessage, SerializerFeature.WriteMapNullValue));
         if (kafkaProperties.getTransaction()) {
-            producer2.send(record);
+            producer2.send(record).get();
         } else {
-            producer2.send(record);
+            producer2.send(record).get();
         }
     }