Functions
rstring createMessageRemoveTopicPartition(list<tuple<rstring topic, int32 partition>> topicPartitionsToRemove)
Creates the JSON message to remove multiple topic-partitions from the operator.
Parameters
-
topicPartitionsToRemove: specifies a list of topic partitions to remove
Returns
-
A JSON string to be submitted to the KafkaConsumer input port
rstring createMessageAddTopicPartition(list<tuple<rstring topic, int32 partition, int64 offset>> topicPartitionsToAdd)
Creates the JSON message to add multiple topic-partitions to the operator. The operator will begin consuming from the topic-partitions at the specified offset,
- To begin consuming from the end of a topic-partition, set the offset value to -1
- To begin consuming from the beginning of a topic-partition, set the offset value to -2
Parameters
-
topicPartitionsToAdd: A list of topic-partitions to subscribe to along with the corresponding offset number to begin consuming from.
Returns
-
A JSON string to be submitted to the KafkaConsumer input port
rstring createMessageRemoveTopicPartition(rstring topic, int32 partition)
Creates the JSON message to remove a single topic-partition from the operator.
Parameters
-
topic: The topic to unsubscribe from
-
partition: The partition to unsubscribe from
Returns
-
A JSON string to be submitted to the KafkaConsumer input port
rstring createMessageAddTopicPartition(rstring topic, int32 partition, int64 offset)
Creates the JSON message to add a single topic-partition to the operator and to begin consuming at the specified offset.
- To begin consuming from the end of a topic-partition, set the offset value to -1
- To begin consuming from the beginning of a topic-partition, set the offset value to -2
Parameters
-
topic: The topic to subscribe to
-
partition: The partition number to assign to
-
offset: The offset of the topic-partition to begin consuming from
Returns
-
A JSON string to be submitted to the KafkaConsumer input port