Ø kafka_close()
Close a Consumer connection
Ø kafka_commit()
Commit the current consumer offset position
Ø 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