org.apache.storm.kafka

Class KafkaUtilsTest

java.lang.Object

org.apache.storm.kafka.KafkaUtilsTest

public class KafkaUtilsTest
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
KafkaUtilsTest()

Method Summary

Modifier and Type	Method and Description
void	assignAllPartitionsToOneTask()
void	assignInvalidTask()
void	assignOnePartitionPerTask()
void	assignTwoPartitionsPerTask()
void	brokerIsDown()
void	fetchMessage()
void	fetchMessagesWithInvalidOffsetAndDefaultHandlingDisabled()
void	fetchMessagesWithInvalidOffsetAndDefaultHandlingEnabled()
void	generateTupelsWithValueScheme()
void	generateTuplesWithKeyAndKeyValueScheme()
void	generateTuplesWithMessageAndMetadataScheme()
void	generateTuplesWithoutKeyAndKeyValueScheme()
void	generateTuplesWithValueAndStringMultiSchemeWithTopic()
void	generateTuplesWithValueSchemeAndKeyValueMessage()
void	getOffsetFromConfigAndDontForceFromStart()
void	getOffsetFromConfigAndFroceFromStart()
void	moreTasksThanPartitions()
void	runPartitionToTaskMappingTest(int numPartitions, int partitionsPerTask)
void	setup()
void	shutdown()
void	topicDoesNotExist()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaUtilsTest

public KafkaUtilsTest()

Method Detail

setup

public void setup()

shutdown

public void shutdown()

topicDoesNotExist

public void topicDoesNotExist()
                       throws java.lang.Exception

Throws:

java.lang.Exception

brokerIsDown

public void brokerIsDown()
                  throws java.lang.Exception

Throws:

java.lang.Exception

fetchMessage

public void fetchMessage()
                  throws java.lang.Exception

Throws:

java.lang.Exception

fetchMessagesWithInvalidOffsetAndDefaultHandlingDisabled

public void fetchMessagesWithInvalidOffsetAndDefaultHandlingDisabled()
                                                              throws java.lang.Exception

Throws:

java.lang.Exception

fetchMessagesWithInvalidOffsetAndDefaultHandlingEnabled

public void fetchMessagesWithInvalidOffsetAndDefaultHandlingEnabled()
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

getOffsetFromConfigAndDontForceFromStart

public void getOffsetFromConfigAndDontForceFromStart()

getOffsetFromConfigAndFroceFromStart

public void getOffsetFromConfigAndFroceFromStart()

generateTuplesWithoutKeyAndKeyValueScheme

public void generateTuplesWithoutKeyAndKeyValueScheme()

generateTuplesWithKeyAndKeyValueScheme

public void generateTuplesWithKeyAndKeyValueScheme()

generateTupelsWithValueScheme

public void generateTupelsWithValueScheme()

generateTuplesWithValueAndStringMultiSchemeWithTopic

public void generateTuplesWithValueAndStringMultiSchemeWithTopic()

generateTuplesWithValueSchemeAndKeyValueMessage

public void generateTuplesWithValueSchemeAndKeyValueMessage()

generateTuplesWithMessageAndMetadataScheme

public void generateTuplesWithMessageAndMetadataScheme()

assignOnePartitionPerTask

public void assignOnePartitionPerTask()

assignTwoPartitionsPerTask

public void assignTwoPartitionsPerTask()

assignAllPartitionsToOneTask

public void assignAllPartitionsToOneTask()

runPartitionToTaskMappingTest

public void runPartitionToTaskMappingTest(int numPartitions,
                                          int partitionsPerTask)

moreTasksThanPartitions

public void moreTasksThanPartitions()

assignInvalidTask

public void assignInvalidTask()