@Test
public void sendRebalance() throws Exception {

  Set<Integer> assignment = singleton(0);
  doNothing().when(underTest).sendEvent(any());
  underTest.sendRebalance(assignment);
  verify(underTest).sendEvent(new Rebalance(assignment));
}