You can use the IBM® Integration Bus Kafka nodes to produce and consume messages on Kafka topics.
You can use the KafkaProducer node to publish messages that are generated from within your message flow to a topic that is hosted on a Kafka server. The published messages are then delivered by the Kafka server to all topic consumers (subscribers). You can use a KafkaConsumer node in a message flow to subscribe to a specified topic on a Kafka server. The KafkaConsumer node then receives messages that are published on the Kafka topic, as input to the message flow.
The Kafka nodes are built using the Apache
Kafka client Version 0.10.0.1, and are compatible with Kafka servers
running Version 0.10.0.1 and above. For more information about Kafka
version compatibility, see the Apache Kafka documentation.
Use the KafkaProducer and KafkaConsumer nodes to complete the steps in the following tasks: