Hi,

We are planing to add Kafka transport to ESB. I have shared the Kafka
producer and consumer architecture.


*Kafka Producer*

An ESB connector is used to configure the producer. The messages are sent
with a topic name and are published to the Kafka broker.

HTTP Request ---> Kafka ESB Connector---> Kafka Broker

*Kafka Consumer*

An Inbound endpoint is used to configure the consumer  which creates a
connection to zookeeper and requests messages for a topic/s or topic
filters, consumes messages from Zookeeper and injects them into ESB.

Zookeeper ---> Kafka Inbound Endpoint --> Outbound HTTP



Thanks,
Kathees


-------------
Kathees
Software Engineer,
email: [email protected]
mobile: +94772596173
_______________________________________________
Architecture mailing list
[email protected]
https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture

Reply via email to