Class: Karafka::Params::Metadata

Inherits:

Hash

• Object
• Hash
• Karafka::Params::Metadata

Defined in:

lib/karafka/params/metadata.rb

Overview

Simple metadata object that stores all non-message information received from Kafka cluster while fetching the data

Instance Method Summary

• #unknown_last_offset? ⇒ Boolean

  Is the last offset known or unknown.

Instance Method Details

#unknown_last_offset? ⇒ Boolean

Returns is the last offset known or unknown.

Returns:

• (Boolean) —

  is the last offset known or unknown

# File 'lib/karafka/params/metadata.rb', line 30

def unknown_last_offset?
  self['unknown_last_offset']
end