struct Kafka::Message

• Kafka::Message
• Struct
• Value
• Object

Defined in:

kafka/message.cr

Constructors

• .new(msg : LibRdKafka::Message)

Instance Method Summary

• #err : RdKafka::Error?
• #key : Slice(UInt8)
• #offset : Int64?
• #partition : Int32
• #payload : Slice(UInt8)
• #timestamp : Int64?
• #topic

Constructor Detail

Instance Method Detail