Functions: com.ibm.streamsx.kafka 3.2.2

Kafka Toolkit > com.ibm.streamsx.kafka 3.2.2 > Functions

Functions

createMessageAddTopic(rstring)

Creates the JSON message to add a single topic to the operator's subscription to begin consuming from the default position.

createMessageAddTopicPartition(list<Control.TopicPartition>)

Creates the JSON message to add multiple topic partitions to the operator's partition assignment.

createMessageAddTopicPartition(list<Control.TopicPartitionOffset>)

Creates the JSON message to add multiple topic partitions to the operator's partition assignment.

createMessageAddTopicPartition(rstring, int32)

Creates the JSON message to add a single topic partition to the operator's partition assignment and to begin consuming at the default position.

createMessageAddTopicPartition(rstring, int32, int64)

Creates the JSON message to add a single topic partition to the operator's partition assignment and to begin consuming at the specified offset.

createMessageAddTopics(list<rstring>)

Creates the JSON message to add multiple topics to the operator's subscription to begin consuming from the default position.

createMessageRemoveTopic(rstring)

Creates the JSON message to remove a single topic from the operator's subscription.

createMessageRemoveTopicPartition(list<Control.TopicPartition>)

Creates the JSON message to remove multiple topic partitions from the operator's partition assignment.

createMessageRemoveTopicPartition(rstring, int32)

Creates the JSON message to remove a single topic partition from the operator's partition assignment.

createMessageRemoveTopics(list<rstring>)

Creates the JSON message to remove multiple topics from the operator's subscription.