KafkaEvent Class

A concrete implementation of Kafka event message type.

Constructor

KafkaEvent(*, body: bytes, trigger_metadata: Mapping[str, Datum] | None = None, key: str | None = None, offset: int | None = None, partition: int | None = None, topic: str | None = None, timestamp: str | None = None, headers: list | None = None)

Keyword-Only Parameters

Name	Description
body Required
trigger_metadata	Default value: None
key	Default value: None
offset	Default value: None
partition	Default value: None
topic	Default value: None
timestamp	Default value: None
headers	Default value: None

Methods

get_body

get_body

get_body() -> bytes

Attributes

headers

key

metadata

offset

partition

timestamp

topic