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=