所有建议的客户机的支持摘要

将客户机连接到 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的 文档。