Core

class bci_framework.framework.core.Kafka[source]

Kafka run on a thread.

create_consumer()None[source]

Basic consumer to check stream status and availability.

create_produser()None[source]

The produser is used for stream annotations and markers.

run()None[source]

Start the produser and consumer for Kafka.

set_host(host: str)None[source]

Set the host for kafka.

stop()None[source]

Kill the thread.