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密码认证的主要内容,如果未能解决你的问题,请参考以下文章
Canal——canal server 读取 binlog 到 kafka 然后在使用 canal-adapter
Canal或maxwell实时采集MySQL数据到Kafka