Class: Karafka::Processing::ConsumerGroups::Partitioner

Inherits:

Object

• Object
• Karafka::Processing::ConsumerGroups::Partitioner

Defined in:

lib/karafka/processing/consumer_groups/partitioner.rb

Overview

Basic partitioner for work division. It does not divide any work.

Direct Known Subclasses

Karafka::Pro::Processing::ConsumerGroups::Partitioner

Instance Method Summary

• #call(_topic, messages, _coordinator) {|group, karafka| ... } ⇒ Object
• #initialize(subscription_group) ⇒ Partitioner constructor

  A new instance of Partitioner.

Constructor Details

#initialize(subscription_group) ⇒ Partitioner

Returns a new instance of Partitioner.

Parameters:

• subscription_group (Karafka::Routing::SubscriptionGroup) —

  subscription group

# File 'lib/karafka/processing/consumer_groups/partitioner.rb', line 9

def initialize(subscription_group)
  @subscription_group = subscription_group
end

Instance Method Details

#call(_topic, messages, _coordinator) {|group, karafka| ... } ⇒ Object

Parameters:

• _topic (String) —

  topic name

• messages (Array<Karafka::Messages::Message>) —

  karafka messages

• _coordinator (Karafka::Processing::ConsumerGroups::Coordinator) —

  processing coordinator that will be used with those messages

Yield Parameters:

• group (Integer) —

  id

• karafka (Array<Karafka::Messages::Message>) —

  messages

# File 'lib/karafka/processing/consumer_groups/partitioner.rb', line 19

def call(_topic, messages, _coordinator)
  yield(0, messages)
end