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) Kafka.new(*ApiAdapter.client(consumer_group)) end