From 8a952d3a5f41939b249bc85e7cb3b81ee41ff873 Mon Sep 17 00:00:00 2001
From: winger <winger2049@gmail.com>
Date: Mon, 6 Aug 2018 11:11:57 +0800
Subject: [PATCH] fix bug: kafka get row data for performance

---
 .../alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java
index e88f9354..0eedfa7a 100644
--- a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java
+++ b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaStarter.java
@@ -121,7 +121,7 @@ public class CanalKafkaStarter {
                     Message message = server.getWithoutAck(clientIdentity, kafkaProperties.getCanalBatchSize()); // 获取指定数量的数据
                     long batchId = message.getId();
                     try {
-                        int size = message.getEntries().size();
+                        int size = message.isRaw() ?  message.getRawEntries().size() : message.getEntries().size();
                         if (batchId != -1 && size != 0) {
                             if (!StringUtils.isEmpty(destination.getTopic())) {
                                 Topic topic = new Topic();