private SSPAllocator getSspAllocator(KinesisSystemConsumer consumer)
      throws NoSuchFieldException, IllegalAccessException {
    Field f = consumer.getClass().getDeclaredField("sspAllocator");
    f.setAccessible(true);
    return (SSPAllocator) f.get(consumer);
  }
Helper to simulate and test the life-cycle of record processing from a kinesis stream with a given number of shards
1. Creation of record processors.
2. Initialization of record processors.
3. Processing records via record processors.
4. Calling checkpoint on record processors.
5. Shutting down (due to re-assignment or lease expiration) record processors.
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestKinesisSystemConsumer.java