module Kafka

Represents a broker in a Kafka cluster.

Constants

VERSION

Public Class Methods

new(seed_brokers = nil, **options) click to toggle source

Initializes a new Kafka client.

@see Client#initialize @return [Client]

# File lib/kafka.rb, line 362
def self.new(seed_brokers = nil, **options)
  # We allow `seed_brokers` to be passed in either as a positional _or_ as a
  # keyword argument.
  if seed_brokers.nil?
    Client.new(**options)
  else
    Client.new(seed_brokers: seed_brokers, **options)
  end
end