struct

Kafka::Message

Inherits Struct < Value < Object

Constructors

new(payload : Bytes, key : Bytes)
Source
new(msg : LibKafkaC::Message)
Source

Instance methods

err
Source
key
Source
offset
Source
partition
Source
payload
Source
timestamp
Source