class Kafka::Message

• Kafka::Message
• Reference
• Object

Defined in:

kafka/message.cr

Constructors

• .new(native_message : LibRdKafka::KafkaMessage)

Instance Method Summary

• #err(*args, **options)
• #err(*args, **options, &)
• #key
• #offset(*args, **options)
• #offset(*args, **options, &)
• #partition(*args, **options)
• #partition(*args, **options, &)
• #payload
• #timestamp
• #topic

Constructor Detail

Instance Method Detail