Package com.ibm.streamsx.topology.messaging.kafka

Support for integrating with the Apache Kafka messaging system http://kafka.apache.org.

See: Description

Class Summary

Class	Description
KafkaConsumer	A simple connector to an Apache Kafka cluster for consuming Kafka messages -- subscribing to Kafka topics and creating a TStream<Message>.
KafkaProducer	A simple connector to an Apache Kafka cluster for producing Kafka messages -- publishing a TStream<Message> to Kafka topics.
Util

Package com.ibm.streamsx.topology.messaging.kafka Description

Support for integrating with the Apache Kafka messaging system http://kafka.apache.org.

Connectors are used to create a bridge between topology streams and a Kafka cluster:

• KafkaConsumer - subscribe to Kafka topics and create streams of messages.
• KafkaProducer - publish streams of messages to Kafka topics.

Functionality in this package is provided by the open source SPL toolkit com.ibm.streamsx.messaging release 2.0.0 or later. This requires that the com.ibm.streamsx.messaging toolkit is made available when submitting the application, by either:

• Submitting to an IBM Streams 4.0 or later instance.
• Including the toolkit in the toolkit path specified by the environment variable STREAMS_SPLPATH
• Specifically adding the toolkit using SPL.addToolkit(com.ibm.streamsx.topology.TopologyElement, java.io.File).

Releases of the toolkit are available from: https://github.com/IBMStreams/streamsx.messaging/releases.