Method: Kafka::FFI::Message#payload

Defined in:
lib/kafka/ffi/message.rb

#payload ⇒ String

Returns the message’s payload. When error != nil, will contain a string describing the error.

Returns:

  • (String) —

    Message payload or error string.



96
97
98
99
100
101
102
 
# File 'lib/kafka/ffi/message.rb', line 96

def payload
  if self[:payload].null?
    return nil
  end

  self[:payload].read_string(self[:len])
end