Functions: com.teracloud.streams.kafka 5.0.0
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.