All docs This doc

Versions Compared

Key

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

...

Code Block
languagexml
titlepublishMessages
<kafkaTransport.publishMessages>
	<topic>{$ctx:topic}<<topic>topicName</topic>
</kafkaTransport.publishMessages>
Properties
  • topic: The name of the topic.

Sample configuration

  • Download and install Apache Kafka. For more information, see Apache Kafka documentation
  • Copy the following client libraries from the <KAFKA_HOME>/lib directory to the <ESB_HOME>/repository/components/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
  • Run the following command to start the ZooKeeper server:

    bin/zookeeper-server-start.sh config/zookeeper.properties

    You will see the following log:

  • Run the following command to start the Kafka server
    bin/kafka-server-start.sh config/server.properties
    You will see the following log:


  • Following is a sample proxy service that illustrates how to connect to Kakfa brokers with the init operation and use the publishMessages operation to publish the messages with the topic.

...