如果您需要配置Kafka而沒有安全性,則推薦版本爲0.8.1.1。
從Kafka 0.9版開始,他們引入了帶有SSL和SASL的Kafka安全機制,它將通過JAAS進行配置。因此,在使用WSO2產品(EI,DAS,CEP)配置Kafka時,您需要將此配置文件(jaas.conf)添加到/ repository/conf/identity。
在這種情況下,WSO2產品充當Kafka客戶端,並且jaas.conf中的配置將用於登錄到kafka服務器。請按照Kafka安全文檔[1]配置服務器和客戶端的安全性。
配置爲SASL/Plaintext的jaas.conf文件的示例內容。
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="kafka"
password="kafka-secret"
user_kafka="kafka-secret"
user_ibm="ibm-secret";
};
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="kafka"
password="kafka-secret";
};
請注意,kafka 0.9僅支持SASL/Kerberos身份驗證。請仔細按照與您的Kafka版本相關的Kafka安全文檔進行正確配置。
[1] http://kafka.apache.org/090/documentation.html#security_sasl
好,到目前爲止,我被這個文檔頁面指導:https://docs.wso2.com/display/EI611/Kafka+Inbound+Protocol突然,當前頁示出了在鏈路https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka_2.12-0.11.0.0+Operations。然後按照說明進行操作並打開牆:https://docs.wso2.com/display/ESBCONNECTORS/ Kafka_2.12-0.11.0.0 +連接器+和+入站+終端 - 它說添加流媒體連接器的文件夾,/repository/components/dropins,但沒有文件夾。 https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka+Inbound+Operations。如何保持神智? –
MaMuDragon
下面是一個簡單的問題:如何添加Kafka連接器,因此可以測試帶有kafka監聽器(帶安全性)的入站端點?你需要遵循哪些步驟?有人可以清理文檔嗎? – MaMuDragon
來自WSO2的任何人,甚至有意回覆呢?你聲稱這是官方用戶/開發社區,但不在意迴應.... – MaMuDragon