class TestKafka::Broker
Constants
- DEFAULT_PROPERTIES
Attributes
broker_id[R]
port[R]
Public Class Methods
new(kafka_path, tmp_dir, port, zk_port, broker_id=0, partition_count=1)
click to toggle source
# File lib/test_kafka/broker.rb, line 28 def initialize(kafka_path, tmp_dir, port, zk_port, broker_id=0, partition_count=1) @broker_id = broker_id @port = port @jr = JavaRunner.new("broker_#{broker_id}", tmp_dir, "kafka.Kafka", port, kafka_path, DEFAULT_PROPERTIES.merge( "broker.id" => broker_id, "port" => port, "log.dir" => "#{tmp_dir}/kafka-logs_#{broker_id}", "kafka.csv.metrics.dir" => "#{tmp_dir}/kafka_metrics", "num.partitions" => partition_count, "zookeeper.connect" => "localhost:#{zk_port}" )) end
Public Instance Methods
pid()
click to toggle source
# File lib/test_kafka/broker.rb, line 56 def pid @jr.pid end
start()
click to toggle source
# File lib/test_kafka/broker.rb, line 48 def start @jr.start end
stop()
click to toggle source
# File lib/test_kafka/broker.rb, line 52 def stop @jr.stop end
with_interruption(&block)
click to toggle source
# File lib/test_kafka/broker.rb, line 60 def with_interruption(&block) @jr.with_interruption(&block) end