public final class ContainerTestUtils
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static void |
waitForAssignment(java.lang.Object container,
int partitions)
Wait until the container has the required number of assigned partitions.
|
public static void waitForAssignment(java.lang.Object container, int partitions) throws java.lang.Exception
container
- the container.partitions
- the number of partitions.java.lang.Exception
- an exception.