module Karafka::Connection::ApiAdapter

def consumer(consumer_group)

Returns:
  • (Array) - array with all the consumer arguments including hash with all

Parameters:
  • consumer_group (Karafka::Routing::ConsumerGroup) -- consumer group details 
def consumer(consumer_group)
  settings = { group_id: consumer_group.id }
  settings = fetch_for(:consumer, consumer_group, settings)
  [sanitize(settings)]
end