org.apache.storm.kafka

Class TestUtils

java.lang.Object

org.apache.storm.kafka.TestUtils

public final class TestUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TOPIC

Method Summary

Modifier and Type	Method and Description
static GlobalPartitionInformation	buildPartitionInfo(int numPartitions)
static GlobalPartitionInformation	buildPartitionInfo(int numPartitions, int brokerPort)
static java.util.List<GlobalPartitionInformation>	buildPartitionInfoList(GlobalPartitionInformation partitionInformation)
static KafkaConfig	getKafkaConfig(KafkaTestBroker broker)
static SimpleConsumer	getKafkaConsumer(KafkaTestBroker broker)
static java.util.Properties	getProducerProperties(java.lang.String brokerConnectionString)
static boolean	verifyMessage(java.lang.String key, java.lang.String message, KafkaTestBroker broker, SimpleConsumer simpleConsumer)

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC

public static final java.lang.String TOPIC

See Also:

Constant Field Values

Method Detail

buildPartitionInfo

public static GlobalPartitionInformation buildPartitionInfo(int numPartitions)

buildPartitionInfoList

public static java.util.List<GlobalPartitionInformation> buildPartitionInfoList(GlobalPartitionInformation partitionInformation)

buildPartitionInfo

public static GlobalPartitionInformation buildPartitionInfo(int numPartitions,
                                                            int brokerPort)

getKafkaConsumer

public static SimpleConsumer getKafkaConsumer(KafkaTestBroker broker)

getKafkaConfig

public static KafkaConfig getKafkaConfig(KafkaTestBroker broker)

getProducerProperties

public static java.util.Properties getProducerProperties(java.lang.String brokerConnectionString)

verifyMessage

public static boolean verifyMessage(java.lang.String key,
                                    java.lang.String message,
                                    KafkaTestBroker broker,
                                    SimpleConsumer simpleConsumer)