Sha256: a14757c248a5c733fcd7bfd1ff31e848f16f90ed66f83676853da4ed7b08a87d
Contents?: true
Size: 824 Bytes
Versions: 72
Compression:
Stored size: 824 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
# @param _coordinator [Karafka::Processing::Coordinator] processing coordinator that will
# be used with those messages
# @yieldparam [Integer] group id
# @yieldparam [Array<Karafka::Messages::Message>] karafka messages
def call(_topic, messages, _coordinator)
yield(0, messages)
end
end
end
end
Version data entries
72 entries across 72 versions & 1 rubygems