暂无个人介绍
2024年04月
2024年03月
[mysqld]
binlog_format=ROW
log-slave-updates=no
enforce_gtid_consistency=no
gtid_mode=ON
log-bin=bin
你可以看一下,有没有开这些配置。没有的话开一下,试试。=报错的话,换成:试试。另外需求确保每台机器的server_id是唯一的,不冲突
最好可以贴一下代码,我之前做过类似的需求,也遇到了问题不过解决了已经。可能是jar包版本的问题,或者如果你的kafka是受kerberos安全认证的话,也需要进行安全认证。另外也要确保kafka本身是没有问题的,你可以自己先随便创建一个topic,启动生产者和消费者试一下