Class: Rimless::Consumer::Base::JobContextCoordinator

Inherits:

Struct

• Object
• Struct
• Rimless::Consumer::Base::JobContextCoordinator

Defined in:

lib/rimless/consumer/base.rb

Overview

A structure for Karafka::BaseConsumer#coodinator, within job contexts.

rubocop:disable Lint/StructNewOverride – because :partition is

expected to be overwritten

Instance Attribute Summary

• #partition ⇒ Object

  Returns the value of attribute partition.

• #topic ⇒ Object

  Returns the value of attribute topic.

Instance Attribute Details

#partition ⇒ Object

Returns the value of attribute partition

Returns:

• (Object) —

  the current value of partition

# File 'lib/rimless/consumer/base.rb', line 39

def partition
  @partition
end

#topic ⇒ Object

Returns the value of attribute topic

Returns:

• (Object) —

  the current value of topic

# File 'lib/rimless/consumer/base.rb', line 39

def topic
  @topic
end