binlog消息

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java

@@ -50,9 +50,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
     private BinlogBasePojo binlogChange(GicRecord record) {
         ClerkSyncPojo pojo=new ClerkSyncPojo();
         pojo.setRecordType(record.getRecordType().value());
-        if(record.getDbName().equals(CLERK)) {
+        if(record.getTableName().equals(CLERK)) {
             return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
-        }else if (record.getDbName().equals(STORE)) {
+        }else if (record.getTableName().equals(STORE)) {
             return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
         }else{
             return null;