Uso del cliente Kafka Java

El ejemplo de API de Java™ Kafka es un productor y consumidor de ejemplo que escrito en Java, que utiliza directamente la API Kafka. Este ejemplo puede ejecutarse de manera local o en IBM Cloud®.

Para obtener un rendimiento óptimo con el cliente Java, se recomienda utilizar la versión 2.6.0o posterior. Para obtener más información, consulte restricción conocida sobre llamadas de Java Kafka.

El código de ejemplo se encuentra en el proyecto event-streams-samples GitHub. A pesar de que el ejemplo utiliza la API Kafka para enviar y recibir mensajes, el ejemplo utiliza la API de administración de Event Streams para crear un tema desde el cual envía y recibe mensajes.

Para obtener más información sobre la configuración y ejecución del ejemplo, consulte README.md.

Para obtener una explicación detallada sobre cómo ejecutar el ejemplo, consulte Iniciación a Event Streams.

Cómo utilizar, descargar y ejecutar el ejemplo Liberty for Java

El ejemplo IBM® Liberty for Java™ for IBM Cloud® implementa una aplicación simple que se despliega en el tiempo de ejecución de Liberty. La aplicación utiliza la API Kafka para que Event Streams produzca y consuma mensajes. La aplicación también sirve un frontal web que se puede utilizar para la administración.

Puede encontrar el código de ejemplo en el proyecto event-streams-samples GitHub.

Uso de la propiedad sasl.jaas.config

Si utiliza un cliente Kafka en 0.10.2.1 o posterior, puede utilizar la propiedad sasl.jaas.config para la configuración del cliente en lugar de un archivo JAAS. Para conectarse a Event Streams, establezca sasl.jaas.config como en el ejemplo siguiente:

    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="USERNAME" \
    password="PASSWORD";</code>

USERNAME y PASSWORD son los valores del separador Event Streams Credenciales de servicio en IBM Cloud.

Si utiliza sasl.jaas.config, los clientes que se ejecutan en la misma JVM pueden utilizar credenciales diferentes. Para obtener más información, consulte Configuración de clientes Kafka.

Para un cliente Kafka anterior, debe utilizar el archivo de configuración JAAS para especificar las credenciales. Este mecanismo es menos conveniente, por lo tanto, utilice la propiedad sasl.jaas.config en su lugar.

Migración de un cliente Kafka desde la versión 0.9.X o 0.10.X a versiones de cliente posteriores

Si utiliza los clientes Java, puede utilizar los clientes Kafka disponibles públicamente versión 0.10 o posterior.

Se recomienda pasar de la versión 0.9.X a la última versión. Puede descargar un cliente Kafka desde https://kafka.apache.org/downloads.

Migración de un cliente Kafka a la versión 0.10.2.X o versiones posteriores

A partir de la versión 0.10.2, puede configurar la autenticación SASL directamente en las propiedades del cliente en lugar de utilizar un archivo JAAS. Esta simplificación le permite ejecutar varios clientes en la misma JVM utilizando distintos conjuntos de credenciales, lo que no es posible con un archivo JAAS.

Complete los pasossiguientes:

Suprima el archivo JAAS. La propiedad de JVM java.security.auth.login.config=<PATH TO JAAS> ya no es necesaria.
Añada lo siguiente a las propiedades del cliente:
```
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME" password="PASSWORD";
```
USERNAME y PASSWORD son los valores del separador Event Streams Credenciales de servicio en IBM Cloud.