Class: Karafka::Pro::Processing::ConsumerGroups::VirtualPartitions::Distributors::Base

Inherits:

Object

• Object
• Karafka::Pro::Processing::ConsumerGroups::VirtualPartitions::Distributors::Base

Defined in:

lib/karafka/pro/processing/consumer_groups/virtual_partitions/distributors/base.rb

Overview

Base class for all virtual partition distributors

Direct Known Subclasses

Balanced, Consistent

Instance Method Summary

• #initialize(config) ⇒ Base constructor

  A new instance of Base.

Constructor Details

#initialize(config) ⇒ Base

Returns a new instance of Base.

Parameters:

• config —

  [Karafka::Pro::Routing::Features::ConsumerGroups::VirtualPartitions::Config]

# File 'lib/karafka/pro/processing/consumer_groups/virtual_partitions/distributors/base.rb', line 43

def initialize(config)
  @config = config
end