Module: TestKafka

Defined in:

lib/test_kafka.rb,
lib/test_kafka/broker.rb,
lib/test_kafka/cluster.rb,
lib/test_kafka/version.rb,
lib/test_kafka/zookeeper.rb,
lib/test_kafka/java_runner.rb

Defined Under Namespace

Classes: Broker, Cluster, JavaRunner, Zookeeper

Constant Summary

VERSION =

"0.1.1"

Class Method Summary

• .start(kafka_path, tmp_root = '/tmp', kafka_port = 9092, zk_port = 2181) ⇒ Object

Class Method Details

.start(kafka_path, tmp_root = '/tmp', kafka_port = 9092, zk_port = 2181) ⇒ Object

# 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