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
        # @return [::Kafka::Client] returns a Kafka client
        def call
          Kafka.new(*ApiAdapter.client)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
karafka-1.3.5	lib/karafka/connection/builder.rb
karafka-1.3.4	lib/karafka/connection/builder.rb
karafka-1.3.3	lib/karafka/connection/builder.rb
karafka-1.3.2	lib/karafka/connection/builder.rb
karafka-1.3.1	lib/karafka/connection/builder.rb
karafka-1.3.0	lib/karafka/connection/builder.rb
karafka-1.3.0.rc1	lib/karafka/connection/builder.rb