Using the KafkaProducer and KafkaConsumer nodes within a message flow

Learn how to use a KafkaProducer and KafkaConsumer node to produce and consume messages using a Kafka topic.
OVERVIEW

This tutorial demonstrates a simple message flow that Produces a message using a KafkaProducer node. A seperate flow then consumes the message using a KafkaConsumer node.

This tutorial requires an Apache kafka server. This could be IBM Bluemix Message hub or your own stand alone server.

In IBM Integration Bus, an application is a container for all the resources that are required to create a solution. An application can contain IBM Integration Bus resources, such as flows, message definitions, libraries, and JAR files. An application is used to hold the message flow in this tutorial.

This tutorial takes approximately 5 minutes.
Tutorial Topics
  • KafkaProducer and KafkaConsumer nodes etc
  • Produce a topic message
  • Consume a topic message
Learning outcomes
  • Use IBM Integration Bus to produce and consume messages using the KafkaProducer and KafkaConsumer nodes.