所有建議用戶端的支援摘要

將用戶端連接至 Event Streams

如需如何配置 Java 用戶端以連接至 Event Streams 的相關資訊，請參閱配置用戶端。

使用 SASL PLAIN

請使用下列字串及內容。

• 使用 bootstrap_endpoints 字串作為引導伺服器的清單，並將此主機及埠配對字串傳遞至 Kafka 用戶端。
• 使用 user 和 api_key 屬性作為使用者名稱和密碼。

對於 Java 用戶端，以下範例顯示了最小屬性集，其中 ${USERNAME}, ${PASSWORD}，和 ${BOOTSTRAP_ENDPOINTS} 將被您之前擷取的值取代。

bootstrap.servers=${BOOTSTRAP_ENDPOINTS}
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${USERNAME}" password="${PASSWORD}";
security.protocol=SASL_SSL
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS

如果您使用的 Kafka 用戶端版本早於 0.10.2.1，則不支援 sasl.jaas.config 屬性，您必須在 JAAS 設定檔中提供用戶端設定。

使用 SASL OAUTHBEARER

在配置 Java 用戶端的 SASL 機制之前，有兩個必要條件。

• 支援的最低 Kafka Java 用戶端版本為 3.1.0。
• 需要從 Maven Central 下載其他 JAR 套件，並在類別路徑中提供。

如果在建置系統中使用 Maven，請將下列資訊新增至 pom.xml 檔的相依關係區段中。

<dependency>
    <groupId>com.ibm.cloud.eventstreams</groupId>
    <artifactId>oauth-client</artifactId>
    <version>1.3.1</version>
</dependency>

如果在建置系統中使用 Gradle，請將下列資訊新增至相依關係區段中的檔案 build.gradle。

implementation com.ibm.cloud.eventstreams:oauth-client:1.3.1

請使用下列字串及內容。

• 使用 bootstrap_endpoints 字串作為引導伺服器的清單，並將此主機及埠配對字串傳遞至 Kafka 用戶端。
• 使用 api_key 字串作為 API 金鑰。
• IAMOAuthBearerLoginCallbackHandler 由 jar 套件 com.ibm.cloud.eventstreams:oauth-client:+ 提供。
• IBM Cloud® Identity and Access Management的記號端點 https://iam.cloud.ibm.com/identity/token 配置為使用 jaas 配置中指定的授權類型從 API 金鑰產生記號。 它是在用戶端執行，因此 API 金鑰永遠不會傳送至伺服器端，且提供比長期 API 金鑰更好的安全。
• Cloud Identity and Access Management的金鑰端點 https://iam.cloud.ibm.com/identity/keys 已配置為驗證記號。

對於 Java 用戶端，以下範例顯示了最小屬性集，其中 ${BOOTSTRAP_ENDPOINTS}，和 ${APIKEY} 將被您之前擷取的值取代。

bootstrap.servers=${BOOTSTRAP_ENDPOINTS}
sasl.mechanism=OAUTHBEARER
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required grant_type="urn:ibm:params:oauth:grant-type:apikey" apikey="${APIKEY}";
sasl.login.callback.handler.class=com.ibm.eventstreams.oauth.client.IAMOAuthBearerLoginCallbackHandler
sasl.oauthbearer.token.endpoint.url=https://iam.cloud.ibm.com/identity/token
sasl.oauthbearer.jwks.endpoint.url=https://iam.cloud.ibm.com/identity/keys
security.protocol=SASL_SSL
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS

範例程式碼參照 Event Streams 範例。

如需其他 Kafka 用戶端程式庫，請參閱其說明文件，以瞭解如何實作 OAUTHBEARER 支援。 例如:。

• sarama: 需要實作 AccessTokenProvider 介面。
• librdkafka: 需要實作 oauthbearer_token_refresh_cb 回呼。

如需如何使用 API 金鑰來產生 IBM Cloud IAM 記號的相關資訊，請參閱 IBM Cloud® Identity and Access Management的 文件。