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); } }