KafkaEvent

fastkafka.KafkaEvent

View source

A generic class for representing Kafka events. Based on BaseSubmodel, bound to pydantic.BaseModel

Parameters:

Name	Type	Description	Default
message	BaseSubmodel	The message contained in the Kafka event, can be of type pydantic.BaseModel.	required
key	Optional[bytes]	The optional key used to identify the Kafka event.	None

init

__init__(
    self, message, key=None
)