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