Skip to content

Bots From Extension: kafka

Kafka - Read and Write data to Kafka Servers

This extension provides 2 bots.





Bot @kafka:poll-topic

Bot Position In Pipeline: Source

Poll a Kafka topic for data and read the data

This bot expects a Restricted CFXQL.

Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot

Parameter Name Type Default Value Description
name* Text Topic name
group* Text Consumer group name
offset_reset Text earliest Topic offset reset position. Valid values are 'earliest' or 'latest'
max_wait_time Text 60 Maximum wait time (seconds) for any messages.







Bot @kafka:write-to-topic

Bot Position In Pipeline: Sink

Write data to specified Kafka topic

This bot expects a Restricted CFXQL.

Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot

Parameter Name Type Default Value Description
name* Text Topic name