Soporte al resumen de todos los clientes recomendados

Conexión de su cliente a Event Streams

Para obtener información sobre cómo configurar el cliente Java para que se conecte a Event Streams, consulte Configuración de su cliente.

Utilización de SASL PLAIN

Utilice las siguientes series y propiedades.

• Utilice la serie bootstrap_endpoints como lista de servidores de rutina de carga y pase esta serie de pares de host y puerto al cliente Kafka.
• Utilice las propiedades user y api_key como nombre de usuario y contraseña.

Para un cliente de Java, el siguiente ejemplo muestra el conjunto mínimo de propiedades, donde ${USERNAME}, ${PASSWORD} y ${BOOTSTRAP_ENDPOINTS} deben ser reemplazados por los valores que recuperó anteriormente.

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

Si utiliza un cliente Kafka anterior a la versión 0.10.2.1, la propiedad sasl.jaas.config no es compatible y, en su lugar, debe proporcionar la configuración del cliente en un archivo de configuración JAAS.

Utilización de SASL OAUTHBEARER

Antes de configurar el mecanismo SASL para el cliente Java, hay dos requisitos previos.

• La versión mínima soportada del cliente Kafka Java es 3.1.0.
• El paquete jar adicional debe descargarse de Maven Central y estar disponible en la vía de acceso de clases.

Si Maven se utiliza en el sistema de compilación, añada la siguiente información al archivo pom.xml en la sección de dependencias.

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

Si se utiliza Gradle en el sistema de compilación, añada la siguiente información al archivo build.gradle en la sección de dependencias.

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

Utilice las siguientes series y propiedades.

• Utilice la serie bootstrap_endpoints como lista de servidores de rutina de carga y pase esta serie de pares de host y puerto al cliente Kafka.
• Utilice la serie api_key como clave de API.
• El IAMOAuthBearerLoginCallbackHandler lo proporciona el paquete jar com.ibm.cloud.eventstreams:oauth-client:+.
• El punto final de señal de IBM Cloud® Identity and Access Management https://iam.cloud.ibm.com/identity/token está configurado para generar señal a partir de la clave de API utilizando el tipo de otorgamiento especificado en jaas config. Se realiza en el lado del cliente, por lo que la clave de API nunca se envía al lado del servidor y proporciona una mejor seguridad que una clave de API de larga duración.
• El punto final de clave de Cloud Identity and Access Management https://iam.cloud.ibm.com/identity/keys está configurado para validar la señal.

Para un cliente de Java, el siguiente ejemplo muestra el conjunto mínimo de propiedades, donde ${BOOTSTRAP_ENDPOINTS} y ${APIKEY} deben sustituirse por los valores que recuperó anteriormente.

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

El código de ejemplo hace referencia a los ejemplos deEvent Streams.

Para otras libarias de cliente Kafka, consulte su documentación sobre cómo implementar el soporte de OAUTHBEARER. Por ejemplo:.

• sarama: es necesaria una implementación de la interfaz AccessTokenProvider.
• librdkafka: es necesaria una implementación de la devolución de llamada oauthbearer_token_refresh_cb.

Para obtener información sobre cómo generar una señal de IAM de IBM Cloud utilizando una clave de API, consulte el documento de IBM Cloud® Identity and Access Management.