debezium同步mysql資料庫資料到kafka叢集

• • 一、修改connect-distributed.sh配置
  • 二、修改connect-distributed.properties
  • 三、啟動kafka-connector
  • 四、啟動mysql資料庫debezium連接配接器
  • 五、檢視mysql連接配接器
  • 六、檢視debezium的mysql連接配接器狀态
  • 七、kafka-manager檢視Topic
  • 八、删除mysql連接配接器

一、修改connect-distributed.sh配置

#!/bin/bash

#打開JMX監控
export JMX_PORT=