Toolkit com.ibm.streamsx.kafka 1.9.4

General Information

The Kafka toolkit integrates IBM Streams with Apache Kafka brokers. It can be used with following broker versions:

Additional information

What's new and what has changed

Version

1.9.4

Required Product Version

4.2.0.0

Indexes

Namespaces

Operators

Functions

Types

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<Control.TopicPartition>)
• createMessageAddTopicPartition(list<Control.TopicPartitionOffset>)
• createMessageAddTopicPartition(rstring, int32)
• createMessageAddTopicPartition(rstring, int32, int64)
• createMessageRemoveTopicPartition(list<Control.TopicPartition>)
• createMessageRemoveTopicPartition(rstring, int32)

Types

• Control.TopicPartition
• Control.TopicPartitionOffset
• MessageType.BlobMessage
• MessageType.ConsumerMessageMetadata
• MessageType.StringMessage
• MessageType.TopicPartition