Functions: com.ibm.streamsx.kafka 2.2.1

Functions

createMessageAddTopicPartition(list<Control.TopicPartition>): Creates the JSON message to add multiple topic-partitions to the operator.
createMessageAddTopicPartition(list<Control.TopicPartitionOffset>): Creates the JSON message to add multiple topic-partitions to the operator.
createMessageAddTopicPartition(rstring, int32): Creates the JSON message to add a single topic-partition to the operator 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 and to begin consuming at the specified offset.
createMessageRemoveTopicPartition(list<Control.TopicPartition>): Creates the JSON message to remove multiple topic-partitions from the operator.
createMessageRemoveTopicPartition(rstring, int32): Creates the JSON message to remove a single topic-partition from the operator.