@Test
public void runChainNoDataToLandException() throws Exception {

  when(offsetManager.getCommittedOffsets(TOPIC_NAME)).thenReturn(singletonMap(0, 100L));
  when(offsetManager.getLatestOffsets(TOPIC_NAME)).thenReturn(singletonMap(0, 100L));
  underTest.runChain(partitionColumnValue);
  verify(emitter, never()).emit(any());
}