Class: Karafka::Params::Metadata

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

Overview

Single message / params metadata details that can be accessed without the need for the payload deserialization

Instance Attribute Summary collapse

Instance Attribute Details

#create_time ⇒ Object

Returns the value of attribute create_time

Returns:

  • (Object) —

    the current value of create_time



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def create_time
  @create_time
end

#deserializer ⇒ Object

Returns the value of attribute deserializer

Returns:

  • (Object) —

    the current value of deserializer



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def deserializer
  @deserializer
end

#headers ⇒ Object

Returns the value of attribute headers

Returns:

  • (Object) —

    the current value of headers



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def headers
  @headers
end

#is_control_record ⇒ Object

Returns the value of attribute is_control_record

Returns:

  • (Object) —

    the current value of is_control_record



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def is_control_record
  @is_control_record
end

#key ⇒ Object

Returns the value of attribute key

Returns:

  • (Object) —

    the current value of key



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def key
  @key
end

#offset ⇒ Object

Returns the value of attribute offset

Returns:

  • (Object) —

    the current value of offset



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def offset
  @offset
end

#partition ⇒ Object

Returns the value of attribute partition

Returns:

  • (Object) —

    the current value of partition



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def partition
  @partition
end

#receive_time ⇒ Object

Returns the value of attribute receive_time

Returns:

  • (Object) —

    the current value of receive_time



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def receive_time
  @receive_time
end

#topic ⇒ Object

Returns the value of attribute topic

Returns:

  • (Object) —

    the current value of topic



7
8
9
 
# File 'lib/karafka/params/metadata.rb', line 7

def topic
  @topic
end