canal里如何配置kafka密码认证

Posted 雅冰石

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了canal里如何配置kafka密码认证相关的知识,希望对你有一定的参考价值。

#登录canal server,修改配置文件,添加kafka密码认证信息

vi /opt/canal-server/conf/canal.properties

添加以下三行内容:

kafka.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required  username='admin'  password='密码';

kafka.sasl.mechanism=PLAIN

kafka.security.protocol=SASL_PLAINTEXT

#重启两台canal server

systemctl stop canal-server

systemctl start canal-server

#检查服务状态

systemctl status canal-server

以上是关于canal里如何配置kafka密码认证的主要内容,如果未能解决你的问题,请参考以下文章

配置kafka密码认证

Canal——canal server 读取 binlog 到 kafka 然后在使用 canal-adapter

canal+mysql+kafka安装配置

Canal或maxwell实时采集MySQL数据到Kafka

Canal或maxwell实时采集MySQL数据到Kafka

canal1.1.5 配置kafka