Module: Karafka::Connection::Builder

Defined in:

lib/karafka/connection/builder.rb

Overview

Builder used to construct Kafka client

Class Method Summary

• .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

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

def call(consumer_group)
  settings = ApiAdapter.client(consumer_group)

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