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