Toolkit com.ibm.streamsx.kafka 1.5.0

Kafka Toolkit > com.ibm.streamsx.kafka 1.5.0

General Information

The Kafka toolkit integrates IBM Streams with Apache Kafka brokers.

Version

1.5.0

Required Product Version

4.2.0.0

Indexes

Namespaces

Operators

Functions

Namespaces

com.ibm.streamsx.kafka

This SPL namespace contains all functions and operators that are required to integrate with Kafka message brokers.

Operators

• KafkaConsumer
• KafkaProducer

Functions

• createMessageAddTopicPartition(list<tuple<rstring topic, int32 partition, int64 offset>>)
• createMessageAddTopicPartition(rstring, int32, int64)
• createMessageRemoveTopicPartition(list<tuple<rstring topic, int32 partition>>)
• createMessageRemoveTopicPartition(rstring, int32)