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