canal配置kafka sasl認(rèn)證

環(huán)境: canal 1.1.4 + kafka2.0

kafka認(rèn)證方式: 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文件夾里面 加一個(gè)jaas.conf的文件

???? 文件內(nèi)容(注意密碼后面的;符號(hào)必須有):?? 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=寫(xiě)上你的路徑/jaas.conf"

kafka消費(fèi)端配置sasl認(rèn)證:

#開(kāi)啟認(rèn)證

security.protocol=SASL_PLAINTEXT

sasl.mechanism=SCRAM-SHA-256

#認(rèn)證配置 (最后一個(gè);符號(hào)不要少)

kafka.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username=test_name password=test1234;

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容