kafka单个partition的发送未改为同步发送的bug fix

This commit is contained in:
mcy
2018-11-07 11:37:16 +08:00
parent bc298bedd5
commit b71e299161

View File

@@ -105,7 +105,7 @@ public class CanalKafkaProducer implements CanalMQProducer {
canalDestination.getPartition(),
null,
JSON.toJSONString(flatMessage));
producer2.send(record);
producer2.send(record).get();
} catch (Exception e) {
logger.error(e.getMessage(), e);
// producer.abortTransaction();