接下来,如何捕获 yugabyte db 中的数据变化? 发布更改日志。
它工作正常。但是,yb-connector.jar 在重新启动 yugabyte db 后不会恢复发布更改数据日志。
执行的命令:
wget -O yb-cdc-connector.jar https://github.com/yugabyte/yb-kafka-connector/blob/master/yb-cdc/yb-cdc-connector.jar?raw=true
1号航站楼:
###start yugabyte db
/opt/yugabyte/yugabyte-2.0.10.0/bin/yb-ctl --data_dir "/opt/yugabyte/data" start
终端2:
###start load generator
julia "/root/gen_users_yb.jl"
终端3:
###publish change logs
java -jar ./yb-cdc-connector.jar --table_name yugastore.users --master_addrs 127.0.0.1:7100 --log_only
1号航站楼:
###stop yugabyte db
/opt/yugabyte/yugabyte-2.0.10.0/bin/yb-ctl --data_dir "/opt/yugabyte/data" stop
(注意:在 LibPQ Exception 负载生成器退出和 yb-connector 等待时)
终端2:
###restarting load generator
julia "/root/gen_users_yb.jl"
观察:3号终端没有恢复发布日志
请帮助我配置 yb-cdc-connector 在 yb-ctl 重新启动(停止和启动)时恢复打印日志。