环境: canal 1.1.4 + kafka2.0
kafka认证方式: SASL_PLAINTEXT SCRAM-SHA-256
1.canal.properties 里面 最后 加上
canal.mq.properties.security.protocol = SASL_PLAINTEXT
canal.mq.properties.sasl.mechanism = SCRAM-SHA-256
2.canal安装目录 conf文件夹里面 加一个jaas.conf的文件
文件内容(注意密码后面的;符号必须有): KafkaClient { org.apache.kafka.common.security.scram.ScramLoginModule required username="test_name" password="test1234"; };
3.canal安装目录 bin目录 修改startup.sh
if [ -n "$str" ]; then JAVA_OPTS="-server -Xms2048m -Xmx3072m -Xmn1024m -XX:SurvivorRatio=2 -XX:PermSize=96m -XX:MaxPermSize=256m -Xss256k -XX:-UseAdaptiveSizePolicy -XX:MaxTenuringThreshold=15 -XX:+DisableExplicitGC -XX:+UseConcMarkSweepGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSCom pactAtFullCollection -XX:+UseFastAccessorMethods -XX:+UseCMSInitiatingOccupancyOnly -XX:+HeapDumpOnOutOfMemoryError -Djava.security.auth.login.config=写上你的路径/jaas.conf"
kafka消费端配置sasl认证:
#开启认证
security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-256
#认证配置 (最后一个;符号不要少)
kafka.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username=test_name password=test1234;
