Setting up Kafka¶
To use the Kafka connector, download and install Apache Kafka. Before you start configuring the Kafka you also need WSO2 EI and we refer to that location as
Note: The recommended version is kafka. For all available versions of Kafka that you can download, see https://kafka.apache.org/downloads. The recommended Java version is 1.8.
To configure the Kafka connector, copy the following client libraries from the <KAFKA_HOME>/lib
directory to the <PRODUCT_HOME>/repository/components/lib
directory.
- kafka_2.12-1.0.0.jar
- kafka-clients-1.0.0.jar
- metrics-core-2.2.0.jar
- scala-library-2.12.3.jar
- zkclient-0.10.jar
- zookeeper-3.4.10.jar
Run the following command to start the ZooKeeper server:
bin/zookeeper-server-start.sh config/zookeeper.properties
Run the following command to start the Kafka server:
bin/kafka-server-start.sh config/server.properties
Now that you have connected to Kafka, you can start publishing and consuming messages using the Kafka brokers. For more information, see Publishing Messages using Kafka and Consuming Messages using Kafka.
Top