Sha256: 1eacbb8e1c06242594a9d0828b5b5d82e1347a96ba20c71049e8f9655c3ceb85
Contents?: true
Size: 676 Bytes
Versions: 33
Compression:
Stored size: 676 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
# Basic partitioner for work division
# It does not divide any work.
class Partitioner
# @param subscription_group [Karafka::Routing::SubscriptionGroup] subscription group
def initialize(subscription_group)
@subscription_group = subscription_group
end
# @param _topic [String] topic name
# @param messages [Array<Karafka::Messages::Message>] karafka messages
# @yieldparam [Integer] group id
# @yieldparam [Array<Karafka::Messages::Message>] karafka messages
def call(_topic, messages)
yield(0, messages)
end
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems