Method: Kafka::FetchedMessage#headers

Defined in:
lib/kafka/fetched_message.rb

#headers ⇒ Hash<String, String>

Returns the headers of the message.

Returns:

  • (Hash<String, String>) —

    the headers of the message.



38
39
40
 
# File 'lib/kafka/fetched_message.rb', line 38

def headers
  @message.headers
end