Kafka

Ø  kafka_close()

Close a Consumer connection

Ø  kafka_commit()

Commit the current consumer offset position

Ø  kafka_offset()

Set offset(s) for specified partition(s) of the current topic in a consumer group

Ø  kafka_open()

Connect to Kafka server

Ø  kafka_poll()

Return records in a Consumer topic as a table sequence

Ø  kafka_send()

A producer publishes messages to topics