Canal连接kafka实现SASL权限认证

Posted Mr.理

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Canal连接kafka实现SASL权限认证相关的知识，希望对你有一定的参考价值。

  1. 打开kafka的sasl安全认证机制

  1. 在canal的配置conf/canal.properties添加配置

canal.mq.properties.security.protocol = SASL_PLAINTEXT
canal.mq.properties.sasl.mechanism = PLAIN
canal.mq.sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="密码";
kafka.sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required username='admin' password='密码';
kafka.sasl.mechanism = PLAIN
kafka.security.protocol = SASL_PLAINTEXT

  1. 重启canal

仅供参考

以上是关于Canal连接kafka实现SASL权限认证的主要内容，如果未能解决你的问题，请参考以下文章

kakfa 安全机制

go kafka 配置SASL认证及实现SASL PLAIN认证功能

Kafka身份认证与权限控制配置

Kafka增加安全验证安全认证，SASL认证，并通过spring boot-Java客户端连接配置

kafka使用SASL/PLAIN认证

配置kafka密码认证