org.apache.storm.kafka

Class KafkaTestBroker

java.lang.Object

org.apache.storm.kafka.KafkaTestBroker

public class KafkaTestBroker
extends java.lang.Object

Date: 11/01/2014 Time: 13:15

Constructor Summary

Constructors

Constructor and Description
KafkaTestBroker()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getBrokerConnectionString()
int	getPort()
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaTestBroker

public KafkaTestBroker()

Method Detail

getBrokerConnectionString

public java.lang.String getBrokerConnectionString()

getPort

public int getPort()

shutdown

public void shutdown()