Kafka broker
KafkaBroker
¶
Bases: Broker
Implementation of the broker for Kafka
createSubscription()
async
¶
Creates a subscription to a data stream.
RETURNS | DESCRIPTION |
---|---|
None
|
disconnect()
async
¶
Closes the connection to the server.
RETURNS | DESCRIPTION |
---|---|
None
|
get_message()
¶
Get the published messages of the subscription.
RETURNS | DESCRIPTION |
---|---|
iterator
|
An async iterator for the messages.
TYPE:
|
publish_event(event)
async
¶
Publish an event to a connected data stream.
PARAMETER | DESCRIPTION |
---|---|
event |
The event to be published.
TYPE:
|
RETURNS | DESCRIPTION |
---|---|
None
|