第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會(huì)有你想問的

具有 Kerberos 身份驗(yàn)證的 PCF Kafka - 在本地運(yùn)行但在 PCF 中失敗

具有 Kerberos 身份驗(yàn)證的 PCF Kafka - 在本地運(yùn)行但在 PCF 中失敗

慕碼人8056858 2023-05-24 17:33:52
使用 Kerberos 身份驗(yàn)證通過 SpringBoot 連接到 Kafka 時(shí)遇到問題。我正在使用具有以下詳細(xì)信息的自定義 Kafka 連接管理器 -          bootstrap-servers-sasl: node1:9094, node2:9094, node3:9094          protocol: SASL_SSL          mechanism: GSSAPI          kerberos:            service:              name: kfkusr          jaas:             config: "com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true storeKey=true keyTab=\"#keytab-name#\" principal=\"abc/node2@domain.NET\";"where#keytab-name#將在運(yùn)行時(shí)被以下值替換為 -我的本地電腦 -C:/Users/MyPC/AppData/Local/Temp/abc.node2_d2254866264751402128.keytabPCF-/home/vcap/tmp/abc.node2_d2215947326380395062.keytab在本地應(yīng)用程序運(yùn)行良好,消息將發(fā)送到 Kafka。但是當(dāng)在 PCF 上運(yùn)行時(shí)失敗并出現(xiàn)以下異常 -2019-08-09T14:40:46.481-05:00 [APP/PROC/WEB/0] [OUT] WARN [9f-3868cbe47d81] org.apache.kafka.clients.NetworkClient o.a.k.c.NetworkClient.processDisconnection(NetworkClient.java:585) - ||||||||||||||Connection to node -1 terminated during authentication. This may indicate that authentication failed due to invalid credentials.......Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms......Exception thrown when sending a message with key='null' and payload='<my payload>' to topic <test_topic> :: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
查看完整描述

1 回答

?
絕地?zé)o雙

TA貢獻(xiàn)1946條經(jīng)驗(yàn) 獲得超4個(gè)贊

好的..我去解決這個(gè)問題..可能對(duì)其他被困在這個(gè)問題上的人有幫助。


首先,我在 Producer Config 屬性中設(shè)置了 krb5.conf 文件。該文件包含主機(jī)、領(lǐng)域的詳細(xì)信息以及使用 kerberos 發(fā)現(xiàn)服務(wù)所需的其他詳細(xì)信息


System.setProperty("java.security.krb5.conf",  <path to conf file>);

而不是直接在屬性中設(shè)置 jaas 配置,我創(chuàng)建了 jaas conf 文件并在系統(tǒng)屬性中設(shè)置它 -


在代碼是這樣的之前 -


props.put("sasl.jaas.config", jaasConfig);

更改后 -


System.setProperty("java.security.auth.login.config", jaasFile.getPath());

示例 Jaas 配置文件jaas_client.conf結(jié)構(gòu) -


KafkaClient {

com.sun.security.auth.module.Krb5LoginModule required

useKeyTab=true

storeKey=true

keyTab="#keytab-name#" 

principal="#principal#";

};

文件中的 PS ,我在更新到 keytab 文件的實(shí)際路徑和具有實(shí)際值的值jaas_client.conf之后重寫文件,然后設(shè)置為#keytab-name##principal#SystemProperties


當(dāng)使用以下屬性啟用調(diào)試時(shí),可以設(shè)置調(diào)試模式以查看 JaaS 身份驗(yàn)證和票務(wù)日志 -


System.setProperty("sun.security.krb5.debug", ""+<true/false>);


查看完整回答
反對(duì) 回復(fù) 2023-05-24
  • 1 回答
  • 0 關(guān)注
  • 271 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)