init

src/main/java/com/gic/message/service/impl/KafkaMessageServiceImpl.java

@@ -2,6 +2,7 @@ package com.gic.message.service.impl;
 
 import com.alibaba.fastjson.JSON;
 import com.gic.binlog.base.entity.GicRecord;
+import com.gic.message.service.MessageHandler;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -16,6 +17,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
     @Override
     public void onMessage(ConsumerRecord<String, GicRecord> consumerRecord) {
         log.info("接收kafka消息，内容为111："+consumerRecord.value());
-        this.messageHandlerInit.getHandler().get(consumerRecord.value().getTableName()).handler(consumerRecord);
+        MessageHandler handler = this.messageHandlerInit.getHandler().get(consumerRecord.value().getTableName());
+        if(handler != null){
+            handler.handler(consumerRecord);
+        }
     }
 }