class Karafka::Connection::Client

def initialize(consumer_group)

Returns:
  • (Karafka::Connection::Client) - group consumer that can subscribe to

Parameters:
  • consumer_group (Karafka::Routing::ConsumerGroup) -- consumer group for which 
def initialize(consumer_group)
  @consumer_group = consumer_group
  Persistence::Client.write(self)
end