|
@@ -55,7 +55,7 @@ canal.conf:
|
|
|
hbase.zookeeper.quorum: slave1
|
|
hbase.zookeeper.quorum: slave1
|
|
|
hbase.zookeeper.property.clientPort: 2181
|
|
hbase.zookeeper.property.clientPort: 2181
|
|
|
zookeeper.znode.parent: /hbase
|
|
zookeeper.znode.parent: /hbase
|
|
|
- mqTopics: # MQ topic租, 如果是kafka或者rockeMQ模式可配置此项, 与canalInstances不能并存
|
|
|
|
|
|
|
+ mqTopics: # MQ topic组, 如果是kafka或者rockeMQ模式可配置此项, 与canalInstances不能并存
|
|
|
- mqMode: kafka # MQ的模式: kafak/rocketMQ
|
|
- mqMode: kafka # MQ的模式: kafak/rocketMQ
|
|
|
topic: example # MQ topic
|
|
topic: example # MQ topic
|
|
|
groups: # group组
|
|
groups: # group组
|
|
@@ -542,4 +542,4 @@ bin/startup.sh
|
|
|
#### 验证
|
|
#### 验证
|
|
|
1. 新增mysql mytest.user表的数据, 将会自动同步到es的mytest_user索引下面, 并会打出DML的log
|
|
1. 新增mysql mytest.user表的数据, 将会自动同步到es的mytest_user索引下面, 并会打出DML的log
|
|
|
2. 修改mysql mytest.role表的role_name, 将会自动同步es的mytest_user索引中的role_name数据
|
|
2. 修改mysql mytest.role表的role_name, 将会自动同步es的mytest_user索引中的role_name数据
|
|
|
-3. 新增或者修改mysql mytest.label表的label, 将会自动同步es的mytest_user索引中的labels数据
|
|
|
|
|
|
|
+3. 新增或者修改mysql mytest.label表的label, 将会自动同步es的mytest_user索引中的labels数据
|
wdlily