module TestKafka

Constants

VERSION

Public Class Methods

start(kafka_path, tmp_root='/tmp', kafka_port=9092, zk_port=2181) click to toggle source

# File lib/test_kafka.rb, line 5
def self.start(kafka_path, tmp_root='/tmp', kafka_port=9092, zk_port=2181)
  tmp_dir = tmp_root + "/test_kafka"
  FileUtils.rm_rf(tmp_dir)

  TestKafka::Cluster.new(kafka_path, tmp_dir, kafka_port, zk_port).start
end