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