@EnableSyncListener
public class XXApplication {  }

@Service
public class BookInfoIndexSyncTrigger {
    @SyncListener(table = {"book_info"}, type = EventType.UPDATE)
    public void updateBookInfo(long bookId) {
        logger.info("更新同步book_info..." + bookId);
        syncService.syncBookInfoIndexById(bookId);
    }
}

@Service
public class BookBaseInfoIndexSyncTrigger {
    @SyncListener(table = {"book_isbn_info"}, type = EventType.ALL, key = {"book_id"})
    public void updateBookInfoFromIsbn(long bookId) {
        logger.info("ALL 非主表批量同步book_isbn_info..." + bookId);
        syncService.syncBookInfoIndexById(bookId);
    }
}

- 获取当前默认加载文档类型(true则为变更前文档，false则变更后文档)
	SyncContext.getCurrentIsDataBefore();

- 直接获取RowData
    SyncContext.getCurrentRowData();
- 获取文档变更前记录Map(若未加载则返回值为空)
    SyncContext.getCurrentDataBefore();
- 获取文档变更后记录Map(若未加载则返回值为空)
    SyncContext.getCurrentDataAfter();

- 获取变更前字段值(若未加载则返回值为空)
    SyncContext.getBeforeParam(field, clazz)
- 获取变更后字段值(若未加载则返回值为空)
    SyncContext.getAfterParam(field, clazz)
- 根据默认加载文档类型获取参数
    SyncContext.getParam(field, clazz)

canal:
  sync: false

canal:
  # 是否使用dubbo的zookeeper集群配置，如果为true则下面的host,port节点配置将失效，会读取dubbo.registry.address信息,默认fasle
  enable: true
  host: 127.0.0.1
  port: 11111
  destination: example
  username:
  password:

[mysqld]
log-bin=mysql-bin # 开启 binlog
binlog-format=ROW # 选择 ROW 模式
server_id=1 # 配置 MySQL replaction 需要定义，不要和 canal 的 slaveId 重复

    canal.instance.filter.regex=test_lib\\..*