Contents

# frozen_string_literal: true

module Karafka
  module Connection
    # Builder used to construct Kafka client
    module Builder
      class << self
        # Builds a Kafka::Cient 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

11 entries across 11 versions & 1 rubygems

Version	Path
karafka-1.2.13	lib/karafka/connection/builder.rb
karafka-1.2.12	lib/karafka/connection/builder.rb
karafka-1.2.11	lib/karafka/connection/builder.rb
karafka-1.2.10	lib/karafka/connection/builder.rb
karafka-1.2.9	lib/karafka/connection/builder.rb
karafka-1.2.8	lib/karafka/connection/builder.rb
karafka-1.2.7	lib/karafka/connection/builder.rb
karafka-1.2.6	lib/karafka/connection/builder.rb
karafka-1.2.5	lib/karafka/connection/builder.rb
karafka-1.2.4	lib/karafka/connection/builder.rb
karafka-1.2.3	lib/karafka/connection/builder.rb