class Kafka::Message

Defined in:

kafka/message.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(msg : Pointer(LibKafkaC::Message)) #

[View source]

Instance Method Detail

def finalize #

[View source]
def key : Bytes | Nil #

[View source]
def payload : Bytes | Nil #

[View source]
def to_unsafe : Pointer(LibKafkaC::Message) #

[View source]
def valid? #

[View source]