bci_framework.framework.core.
Kafka
Kafka run on a thread.
create_consumer
Basic consumer to check stream status and availability.
create_produser
The produser is used for stream annotations and markers.
run
Start the produser and consumer for Kafka.
set_host
Set the host for kafka.
stop
Kill the thread.