Contents

require "kafka/version"
require "kafka/cluster"
require "kafka/producer"

module Kafka
  def self.new(**options)
    Cluster.new(**options)
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ruby-kafka-0.1.0.pre.alpha	lib/kafka.rb