Class: Karafka::Messages::Seek

Inherits:

Struct

• Object
• Struct
• Karafka::Messages::Seek

Defined in:

lib/karafka/messages/seek.rb

Overview

Note:

#offset can be either the offset value or the time of the offset

“Fake” message that we use as an abstraction layer when seeking back. This allows us to encapsulate a seek with a simple abstraction

(first equal or greater)

Instance Attribute Summary

• #offset ⇒ Object

  Returns the value of attribute offset.

• #partition ⇒ Object

  Returns the value of attribute partition.

• #topic ⇒ Object

  Returns the value of attribute topic.

Instance Attribute Details

#offset ⇒ Object

Returns the value of attribute offset

Returns:

• (Object) —

  the current value of offset

# File 'lib/karafka/messages/seek.rb', line 10

def offset
  @offset
end

#partition ⇒ Object

Returns the value of attribute partition

Returns:

• (Object) —

  the current value of partition

# File 'lib/karafka/messages/seek.rb', line 10

def partition
  @partition
end

#topic ⇒ Object

Returns the value of attribute topic

Returns:

• (Object) —

  the current value of topic

# File 'lib/karafka/messages/seek.rb', line 10

def topic
  @topic
end