WSO2 ESB y Apache Kafka

Este post trata como integrar WSO2 ESB 5.0.0 con Apache Kafka 2.11-0.10.1.1, aunque la documentación del conector habla de utilizar una versión antigua (a día de hoy) yo he utilizado la más reciente sin problemas, he aquí un resumen de los pasos a seguir.

1. Descargar kafka_2.11-0.10.1.1
2. Descargar WSO2 ESB 5.0.0
3. Copiar las librerias de Kafka en el servidor ESB (/repository/components/lib)
   
   
4. Descargar ESB Kafka Connector V1.0.0
5. Iniciar el servidor ESB 
1. Instalar el conector
   
2. Activar el conector
   
6. Iniciar el servidor kafka y crear un topic (testpoc01)

• > bin/zookeeper-server-start.sh config/zookeeper.properties

• > bin/kafka-server-start.sh config/server.properties

• > bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testpoc01

Bueno ahora es tiempo de crear un projecto con el nuevo WSO2 ESB Tooling y probar la integración.

1. Crear multi-maven project
2. Crear ESB Config project
1. Add connector
   
2. Crear un servicio proxy
   
3. Crear un projecto CAR y desplegarlo en el servidor

Es tiempo de probar la integración entre ambos.

Solo a fin de ver los mensajes depositados en Kafka vamos a iniciar el consumidor de linea de comandos que viene con kafka.

> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testpoc01 --from-beginning

Ahora empezaramemos a enviar peticiones SOAP al servicio creado utilizando la herramienta "Try this service"

Finalmente en el consumidor Kafka que hemos iniciado podremos ver los mensajes enviados desde "Try this service"

Enlaces relacionados:

• https://kafka.apache.org/quickstart
• https://docs.wso2.com/display/ESBCONNECTORS/Kafka+Connector

- Enjoy it! -