Skip to content

Kafka publisher

KafkaPublisher

Bases: Publisher

Implementation of a publisher for Kafka

disconnect() async

Closes the connection to the server.

RETURNS DESCRIPTION
None

publish_event(event) async

Publish an event to a connected data stream.

PARAMETER DESCRIPTION
event

The event to be published.

TYPE: Dict[str, Any]

RETURNS DESCRIPTION
None