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

Inherits:

Object

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

Defined in:

lib/karafka/pro/processing/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::VirtualPartitions::Config)

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

def initialize(config)
  @config = config
end