WSO2 EI Kafka inbound endpoint acts as a message consumer. It creates a connection to ZooKeeper and requests messages for a topic.
| 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 |
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.
Follow the steps given below to build the Kafka Inbound Endpoint from the source code.
- Get a clone or download the source from Github.
- Run the following Maven command from the
esb-inbound-kafkadirectory:mvn clean install. - The JAR file for the Kafka Inbound Endpoint is created in the
esb-inbound-kafka/targetdirectory.
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.