@Test
  public void testShutdownDuringReshardWithNoEvents() throws InterruptedException {
    testShutdownDuringReshardHelper(0);
  }
Test the scenario where a processor instance is created for a shard and while it is processing records, it got
re-assigned to the same consumer. This results in a new processor instance owning the shard and this instance
could receive checkpoint calls for the records that are processed by the old processor instance. This test covers
the scenario where the new instance receives the checkpoint call while it is done with the initialization phase and
before it processed any records.
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestKinesisRecordProcessor.java