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