org.apache.storm.kafka

Class ZkCoordinatorTest

java.lang.Object

org.apache.storm.kafka.ZkCoordinatorTest

public class ZkCoordinatorTest
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ZkCoordinatorTest()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	shutdown()
void	testOnePartitionPerTask()
void	testPartitionsChange()

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkCoordinatorTest

public ZkCoordinatorTest()

Method Detail

setUp

public void setUp()
           throws java.lang.Exception

Throws:

java.lang.Exception

shutdown

public void shutdown()
              throws java.lang.Exception

Throws:

java.lang.Exception

testOnePartitionPerTask

public void testOnePartitionPerTask()
                             throws java.lang.Exception

Throws:

java.lang.Exception

testPartitionsChange

public void testPartitionsChange()
                          throws java.lang.Exception

Throws:

java.lang.Exception