Sha256: d1167c2ae78a330e4d9954c659f5b084bf08ec718f46bf6979211a26e0d4d3c8
Contents?: true
Size: 302 Bytes
Versions: 15
Compression:
Stored size: 302 Bytes
Contents
# frozen_string_literal: true
module Karafka
# Strategies for Kafka partitions assignments
module AssignmentStrategies
# Standard RoundRobin strategy
class RoundRobin < SimpleDelegator
def initialize
super(Kafka::RoundRobinAssignmentStrategy.new)
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems