Contents

# frozen_string_literal: true

module Karafka
  module Connection
    # Builder used to construct Kafka client
    module Builder
      class << self
        # 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
        def call(consumer_group)
          settings = ApiAdapter.client(consumer_group)

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

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
karafka-1.4.15	lib/karafka/connection/builder.rb
karafka-1.4.14	lib/karafka/connection/builder.rb
karafka-1.4.13	lib/karafka/connection/builder.rb
karafka-1.4.12	lib/karafka/connection/builder.rb
karafka-1.4.11	lib/karafka/connection/builder.rb
karafka-1.4.10	lib/karafka/connection/builder.rb
karafka-1.4.9	lib/karafka/connection/builder.rb
karafka-1.4.8	lib/karafka/connection/builder.rb
karafka-1.4.7	lib/karafka/connection/builder.rb
karafka-1.4.6	lib/karafka/connection/builder.rb
karafka-1.4.5	lib/karafka/connection/builder.rb
karafka-1.4.4	lib/karafka/connection/builder.rb
karafka-1.4.3	lib/karafka/connection/builder.rb