class Kafka::EC2

Constants

VERSION

Attributes

assignment_strategy_factory[R]

Public Class Methods

assignment_strategy_classes() click to toggle source
# File lib/kafka/ec2.rb, line 18
def assignment_strategy_classes
  @assignment_strategy_classes ||= {}
end
with_assignment_strategy_factory(factory) { || ... } click to toggle source
# File lib/kafka/ec2.rb, line 11
def with_assignment_strategy_factory(factory)
  @assignment_strategy_factory = factory
  yield
ensure
  @assignment_strategy_factory = nil
end