Functions: Kafka Toolkit

Kafka Toolkit > Functions

Functions

createMessageAddTopicPartition(list<tuple<rstring topic, int32 partition, int64 offset>>)

Creates the JSON message to add multiple topic-partitions to the operator.

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<tuple<rstring topic, int32 partition>>)

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.