module Karafka::Connection::Builder

Builder used to construct Kafka client

Public Class Methods

call(consumer_group) click to toggle source

Builds a Kafka::Client instance that we use to work with Kafka cluster @param consumer_group [Karafka::Routing::ConsumerGroup] consumer group for which we want

to have a new Kafka client

@return [::Kafka::Client] returns a Kafka client

# File lib/karafka/connection/builder.rb, line 12
def call(consumer_group)
  settings = ApiAdapter.client(consumer_group)

  Kafka.new(
    settings[0],
    **settings[1]
  )
end