Kafka WSO2 EI Inbound Endpoint

WSO2 EI Kafka inbound endpoint acts as a message consumer. It creates a connection to ZooKeeper and requests messages for a topic.

Compatibility

Inbound Endpoint version	Supported Kafka version	Supported WSO2 ESB/EI version
1.2.0	2.12-3.5.1	EI 6.6.0 , MI 1.2.0 , MI 4.x.x
1.0.12	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0 , MI 1.1.0
1.0.11	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0 , MI 1.1.0
1.0.10	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0 , MI 1.1.0
1.0.9	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0 , MI 1.1.0
1.0.8	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0 , MI 1.1.0
1.0.7	2.12-2.2.1	EI 6.1.1, EI 6.4.0, EI 6.5.0
1.0.6	2.12-1.0.0	EI 6.1.1, EI 6.4.0, EI 6.5.0
1.0.5	2.12-1.0.0	EI 6.2.0, ESB 4.9.0
1.0.4	2.12-1.0.0	EI 6.2.0, ESB 4.9.0
1.0.3	2.12-1.0.0	EI 6.2.0, ESB 4.9.0
1.0.2	2.12-1.0.0	ESB 4.9.0
1.0.1	2.12-1.0.0	ESB 4.9.0
1.0.0	2.12-1.0.0	EI 6.1.1, ESB 4.9.0, ESB 5.0.0

Getting started

To get started with the inbound endpoint, go to Configuring Kafka Inbound Endpoint. Once you have completed your configurations, you can consume the messages that are produced by the Kafka producer via a topic.

Building from the source

Follow the steps given below to build the Kafka Inbound Endpoint from the source code.

1. Get a clone or download the source from Github.
2. Run the following Maven command from the esb-inbound-kafka directory: mvn clean install.
3. The JAR file for the Kafka Inbound Endpoint is created in the esb-inbound-kafka/target directory.

How you can contribute

As an open source project, WSO2 extensions welcome contributions from the community. Check the issue tracker for open issues that interest you. We look forward to receiving your contributions.