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)
container
- the container.partitions
- the number of partitions.java.lang.IllegalStateException
- if the operation cannot be completed (since 2.3.4) as
expected.ContainerTestUtilsException
- if the call to the container's
getAssignedPartitions() method fails.