Class: Karafka::Messages::Seek

Inherits:
Struct
  • Object
show all
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 collapse

Instance Attribute Details

#offsetObject

Returns the value of attribute offset

Returns:

  • (Object)

    the current value of offset



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

def offset
  @offset
end

#partitionObject

Returns the value of attribute partition

Returns:

  • (Object)

    the current value of partition



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

def partition
  @partition
end

#topicObject

Returns the value of attribute topic

Returns:

  • (Object)

    the current value of topic



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

def topic
  @topic
end