Functions: com.ibm.streamsx.messagehub 1.9.3
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.