Module: Karafka::Connection::Builder

Defined in:: lib/karafka/connection/builder.rb

Overview

Builder used to construct Kafka client

Class Method Summary collapse

.call(consumer_group) ⇒ ::Kafka::Client

Builds a Kafka::Client instance that we use to work with Kafka cluster.

Class Method Details

.call(consumer_group) ⇒ `::Kafka::Client`

Builds a Kafka::Client instance that we use to work with Kafka cluster

Parameters:

consumer_group (Karafka::Routing::ConsumerGroup) —

consumer group for which we want to have a new Kafka client

Returns:

(::Kafka::Client) —

returns a Kafka client



12
13
14

# File 'lib/karafka/connection/builder.rb', line 12

def call(consumer_group)
  Kafka.new(*ApiAdapter.client(consumer_group))
end