Si estamos pensando en utilizar kafka Confluent, podremos adquirir la libreria  jms-kafka-client, la cual  es

una implementación que utiliza el protocolo de  Apache Kafka para hablar con uno o más topicos de Kafka.

Para empezar debemos realizar las configuraciones necesarias para crear nuestro proyecto en java,

puedo recomendar IntelliJ IDEA ya que es liviano  y con entorno amigable. https://www.jetbrains.com/idea/

 

Creamos un proyecto java en nuestro IDE de preferencia  y utilizando MAVEN, podremos observar una

estructura como esta:

Ahora, pasaremos a modificar solo dos archivos el .java y pom; se encuentran apuntados con flechas rojas.

En el pom colocaremos las librerias que requerimos de la siguiente manera:

 

Ejecutamos el archivo POM para descargar las librerias descritas.

Luego procedemos a copiar nuestro codigo en el archivo java

 

 

Importamos las clases JMS API

 

Empezamos con la codificacion de nuestras clases

Declaramos nuestras propiedades para la conexión con nuestros servidores Kafka, importante tener la LICENCIA Confluent para el uso de la libreria.

Abrimos conexion

Declaramos las sentencias para escribir en la cola

 

Declaramos las sentencias para leer en la cola

 

Concluimos atrapando cualquier error

 

 

ya podemos ejecutar nuestro proyecto…

 

 

Share: