WSO2 ESB Connectors Documentation

All docs This doc
Expand all   Collapse all

Versions Compared

Old Version 10

changes.mady.by.user Kathees Rajendram

Saved on

compared with

New Version 11

changes.mady.by.user Kathees Rajendram

Saved on

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.

...