05 February 2017

WSO2 ESB 5.0.0 Kafka Inbound Protocol

Ahora es tiempo de consumir mensajes de Apache Kafka 2.11-0.10.1.1 usando Kafka Inbound Protocol de  WSO2 ESB 5.0.0.

Los siguientes son los pasos a seguir:
  1. Configuración de librerías
  2. Configuración de la seguridad
  3. Consumo de mensajes

Configuración de librerías

Hay que añadir una librería extra: scala-parser-combinators_2.11-1.0.4.jar para evitar errores del tipo "NoClassDefFoundError: scala/util/parsing/json/json".



Configuración de la seguridad

Luego hay que configurar el modulo JAAS en el servidor WSO2 para poder conectar con los servidores zookeeper.



Consumo de mensajes

La siguiente es una configuración ejemplo para consumir mensajes.




Enlaces relacionados:


- Enjoy it! - 

30 January 2017

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:

- Enjoy it! -