module Kafka::EC2::Ext::ConsumerGroup

Public Class Methods

new(*args, **kwargs) click to toggle source
Calls superclass method
# File lib/kafka/ec2/ext/consumer_group.rb, line 10
def initialize(*args, **kwargs)
  super
  if Kafka::EC2.assignment_strategy_factory
    @assignment_strategy = Kafka::EC2.assignment_strategy_factory.create(cluster: @cluster)
  end
  Kafka::EC2.assignment_strategy_classes[@group_id] = @assignment_strategy.class
end

Public Instance Methods

join_group() click to toggle source
Calls superclass method
# File lib/kafka/ec2/ext/consumer_group.rb, line 18
def join_group
  super
  if Kafka::EC2.assignment_strategy_classes[@group_id] == Kafka::EC2::MixedInstanceAssignmentStrategy
    @assignment_strategy.member_id_to_metadata = @members
  end
end