spring-boot-starter-canal
canal starter
eg(annotation):
@CanalEventListener
public class MyEventListener {
@InsertListenPoint
public void onEvent(CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
//do something...
}
@UpdateListenPoint
public void onEvent1(CanalEntry.RowData rowData) {
//do something...
}
@DeleteListenPoint
public void onEvent3(CanalEntry.EventType eventType) {
//do something...
}
@ListenPoint(destination = "example", schema = "canal-test", table = {"t_user", "test_table"}, eventType = CanalEntry.EventType.UPDATE)
public void onEvent4(CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
//do something...
}
}
eg(interface):
@Component
public class MyEventListener2 implements CanalEventListener {
@Override
public void onEvent(CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
//do something...
}
}
@Component
public class MyEventListener2 implements DmlCanalEventListener {
@Override
public void onInsert(CanalEntry.RowData rowData) {
//do something...
}
@Override
public void onUpdate(CanalEntry.RowData rowData) {
//do something...
}
@Override
public void onDelete(CanalEntry.RowData rowData) {
//do something...
}
}
Config
config |
describe |
canal.client.instances.{destination}.clusterEnabled |
enable cluster mod |
canal.client.instances.{destination}.zookeeperAddress |
zookeeper address(required when clusterEnabled is true) |
canal.client.instances.{destination}.host |
canal server host(required when clusterEnabled is false) |
canal.client.instances.{destination}.port |
canal server port (required when clusterEnabled is false) |
canal.client.instances.{destination}.batchSize |
size when trying to get messages from server |
canal.client.instances.{destination}.acquireInterval |
interval of acquiring the messages |
canal.client.instances.{destination}.filter |
client's subscribe-filter |
canal.client.instances.{destination}.userName |
user name |
canal.client.instances.{destination}.password |
password |
canal.client.instances.{destination}.retryCount |
retry count when error occurred such as IoException. |