class Kafka::ConsumerGroup

def initialize(cluster:, logger:, group_id:, session_timeout:, retention_time:, instrumenter:)
  @cluster = cluster
  @logger = logger
  @group_id = group_id
  @session_timeout = session_timeout
  @instrumenter = instrumenter
  @member_id = ""
  @generation_id = nil
  @members = {}
  @topics = Set.new
  @assigned_partitions = {}
  @assignment_strategy = RoundRobinAssignmentStrategy.new(cluster: @cluster)
  @retention_time = retention_time
end