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

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
karafka-1.4.2	lib/karafka/connection/builder.rb
karafka-1.4.1	lib/karafka/connection/builder.rb
karafka-1.4.0	lib/karafka/connection/builder.rb
karafka-1.4.0.rc2	lib/karafka/connection/builder.rb
karafka-1.4.0.rc1	lib/karafka/connection/builder.rb
karafka-1.3.7	lib/karafka/connection/builder.rb
karafka-1.3.6	lib/karafka/connection/builder.rb