class

Kafka::Message

Inherits Reference < Object

Constructors

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

destroy

Frees resources and hands ownership back to rdkafka.

errstr

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

offset

payload

timestamp

Returns the message timestamp for a consumed message.

to_s(io)

to_unsafe