From 971c9a88c29f6c5f3930107361125703ccc76cb4 Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Tue, 12 Mar 2019 17:07:33 +0800
Subject: [PATCH] modify

---
 .../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 507fabc2..527c47dd 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
@@ -161,7 +161,7 @@ public class CanalKafkaProducer implements CanalMQProducer {
 
             if (record != null) {
                 if (kafkaProperties.getTransaction()) {
-                    producer.send(record);
+                    producer.send(record).get();
                 } else {
                     producer.send(record).get();
                 }
@@ -213,7 +213,7 @@ public class CanalKafkaProducer implements CanalMQProducer {
         if (kafkaProperties.getTransaction()) {
             producer2.send(record);
         } else {
-            producer2.send(record).get();
+            producer2.send(record);
         }
     }