Class: Karafka::Messages::Metadata

Inherits:
Struct
  • Object
show all
Defined in:
lib/karafka/messages/metadata.rb

Overview

Single message metadata details that can be accessed without the need of deserialization.

Instance Attribute Summary collapse

Instance Attribute Details

#deserializer ⇒ Object

Returns the value of attribute deserializer

Returns:

  • (Object) —

    the current value of deserializer



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def deserializer
  @deserializer
end

#headers ⇒ Object

Returns the value of attribute headers

Returns:

  • (Object) —

    the current value of headers



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def headers
  @headers
end

#key ⇒ Object

Returns the value of attribute key

Returns:

  • (Object) —

    the current value of key



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def key
  @key
end

#offset ⇒ Object

Returns the value of attribute offset

Returns:

  • (Object) —

    the current value of offset



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def offset
  @offset
end

#partition ⇒ Object

Returns the value of attribute partition

Returns:

  • (Object) —

    the current value of partition



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def partition
  @partition
end

#received_at ⇒ Object

Returns the value of attribute received_at

Returns:

  • (Object) —

    the current value of received_at



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def received_at
  @received_at
end

#timestamp ⇒ Object

Returns the value of attribute timestamp

Returns:

  • (Object) —

    the current value of timestamp



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def timestamp
  @timestamp
end

#topic ⇒ Object

Returns the value of attribute topic

Returns:

  • (Object) —

    the current value of topic



6
7
8
 
# File 'lib/karafka/messages/metadata.rb', line 6

def topic
  @topic
end