From cdd077b75820b542a69b08ee3bf9c652f481c9f0 Mon Sep 17 00:00:00 2001
From: caoyixiong <32847163+IanCao@users.noreply.github.com>
Date: Thu, 20 Aug 2020 21:18:12 +0800
Subject: [PATCH] FIX NPE When ddl event (#2801)

---
 .../canal/example/kafka/CanalKafkaClientFlatMessageExample.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java b/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java
index 43ae2512..5d5fd2d1 100644
--- a/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java
+++ b/example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java
@@ -117,7 +117,7 @@ public class CanalKafkaClientFlatMessageExample {
                         }
                         for (FlatMessage message : messages) {
                             long batchId = message.getId();
-                            int size = message.getData().size();
+                            int size = message.getData() == null ? 0 : message.getData().size();
                             if (batchId == -1 || size == 0) {
                                 // try {
                                 // Thread.sleep(1000);