Merge pull request #810 from wingerx/master

fix bug: kafka get row data for performance
2018-08-06 12:19:08 +08:00
parent 764e1b6dc0 119c5a6971
commit 7c7ce43455
1 changed files with 1 additions and 1 deletions
@@ -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();