system.kafka
Kafka Functions
The following functions allow you to poll and distribute data with a Kafka system.
📄️ listConnectorInfo
Returns descriptions of all Kafka connectors in PyDictionary format.
📄️ listTopicPartitions
Returns a list of records that match the filter.
📄️ listTopics
Returns a list of topics for the provided connector.
📄️ pollPartition
Returns a list of records polled from a specified partition.
📄️ pollTopic
Returns a list of records from the specified topic.
📄️ seekLatest
Retrieves the last N number of records from a specified topic.
📄️ sendRecord
Sends a record to a specified topic.
📄️ sendRecordAsync
Sends a record to a specified topic asynchronously.