struct

AWSLambdaEvents::Kafka::Record

Inherits JSON::Serializable < Struct < Value < Object

Constructors

new(pull : JSON::PullParser)
Source
new(*, __pull_for_json_serializable pull : JSON::PullParser)
Source

Instance methods

decoded_key
Source
decoded_value
Source
headers

Kafka serialises header byte arrays as JSON arrays of signed int8 values (e.g. [-7, 65, ...]), not base64. Reinterpret with .to_u8! for raw bytes.

Source
offset
Source
partition
Source
timestamp
Source
timestamp_type
Source
topic
Source
value
Source