class Kafka::Message

• Kafka::Message
• Reference
• Object

Defined in:

kafka/message.cr

Constructors

• .new(rkmessage : Pointer(LibKafka::MessageT))

Instance Method Summary

• #destroy

  Frees resources and hands ownership back to rdkafka.

• #errstr : String | Nil

  Returns the error string for an errored rd_kafka_message_t or NULL if there was no error.

• #offset
• #payload
• #timestamp : Int64

  Returns the message timestamp for a consumed message.

• #to_s(io)
• #to_unsafe : Pointer(LibKafka::MessageT)

Constructor Detail

Instance Method Detail