mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Canal Kafka QuickStart (markdown)
@@ -214,9 +214,10 @@ canal.instance.dbPassword = canal
|
||||
```
|
||||
# ...
|
||||
canal_ip =192.168.1.99
|
||||
canal.withoutNetty =**true**
|
||||
canal.withoutNetty = true
|
||||
canal.serverMode = kafka
|
||||
# zk server地址
|
||||
canal.zkServers=192.168.1.110:2181,192.168.1.111:2181,192.168.1.112:2181
|
||||
canal.zkServers=
|
||||
canal.destinations= example
|
||||
# ...
|
||||
canal.instance.global.spring.xml = classpath:spring/default-instance.xml
|
||||
@@ -275,7 +276,7 @@ sh bin/stop.sh
|
||||
### 5.7 使用canal.kafka.client 查看kafka topic中的代码样例
|
||||
```
|
||||
# // 可参考 canal kafka client 中的实现
|
||||
com.alibaba.otter.canal.kafka.client.running.CanalKafkaClientExample
|
||||
com.alibaba.otter.canal.client.running.kafka.CanalKafkaClientExample
|
||||
```
|
||||
### 5.8 参考链接
|
||||
```
|
||||
|
||||
Reference in New Issue
Block a user