這篇文章主要講解了“flink1.12怎么通過kerberos認證讀取kafka數(shù)據(jù)”，文中的講解內(nèi)容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“flink1.12怎么通過kerberos認證讀取kafka數(shù)據(jù)”吧！

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供句容網(wǎng)站建設(shè)、句容做網(wǎng)站、句容網(wǎng)站設(shè)計、句容網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、句容企業(yè)網(wǎng)站模板建站服務(wù)，十余年句容做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

說明

一般我們在使用kafka的時候很少經(jīng)過kerberos認證，通過flink消費kafka數(shù)據(jù)的時候相對比較容易，一般很容易測通。

但是如果kafka有kerberos的認證，相對比較麻煩,結(jié)合官網(wǎng)進行說明。

官方文檔

https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/

主要就是說明需要配置flink-conf.yml以及kafka的配置。

自己配置

這里面涉及三個文件user.keytab、jaas.conf和krb5.conf文件。把這個配置文件配置好后在設(shè)置kafka的屬性就可以了。

kafka的屬性如下:

      props.put("security.protocol", "SASL_PLAINTEXT");
      props.put("sasl.mechanism", "GSSAPI");
      props.put("sasl.kerberos.service.name", "kafka");

以上配置好,flink就可以提交任務(wù)進行kafka的消費了。

感謝各位的閱讀，以上就是“flink1.12怎么通過kerberos認證讀取kafka數(shù)據(jù)”的內(nèi)容了，經(jīng)過本文的學習后，相信大家對flink1.12怎么通過kerberos認證讀取kafka數(shù)據(jù)這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！

文章標題：flink1.12怎么通過kerberos認證讀取kafka數(shù)據(jù)
當前路徑：http://chinadenli.net/article26/ieihjg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供商城網(wǎng)站、搜索引擎優(yōu)化、網(wǎng)站建設(shè)、網(wǎng)站策劃、動態(tài)網(wǎng)站、網(wǎng)站收錄

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)