...
The kafka inbound endpoint acts as a message consumer. It creates a connection to zookeeper ZooKeeper and requests messages for a topic, topics or topic filters.
In order to use the kafka inbound endpoint, you need to download and install Apache Kafka. The recommend recommended version is kafkais kafka_2.9.2-0.8.1.1
or later.
To configure the kafka inbound endpoint, copy the following client libraries from the <KAFKA_HOME>/libs
directory to the <EI_HOME>/lib
directory.
kafka_2.9.2-0.8.1.1.jar
scala-library-2.9.2.jar
zkclient-0.3.jar
zookeeper-3.3.4.jar
metrics-core-2.2.0.jar
Info | ||
---|---|---|
| ||
|
Configuration parameters for a kafka inbound endpoint are XML fragments that represent various properties.
...