Versions Compared

Old Version 3

changes.mady.by.user Former user

Saved on

compared with

New Version Current

changes.mady.by.user Former user

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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
titleNote
  • If you
use
  • are using kafka_2.x.x-0.8.2.
0 or
  • 0 or later, you also need to
add 
  • add the kafka-clients-0.8.x.x.
jar also to
  • jar file to the <EI_HOME>/lib  directory.

  • If you are using a newer version of ZooKeeper, follow the steps below:

      1. Create a directory named conf inside the <EI_HOME>/repository directory.
      2. Create a directory named identity inside the <EI_HOME>/repository/conf directory.
      3. Add the jaas.conf file to the <EI_HOME>/repository/conf/identity directory. This is required because Kerberos authentication is enforced on newer versions of ZooKeeper.

Configuration parameters for a kafka inbound endpoint are XML fragments that represent various properties.

...