EFO will refactor the existing Polling implementation to use the proposed RecordPublisher interface. In order to increase our confidence with this change, we should increase test coverage of the existing implementation.
Improved test coverage for existing Polling consumption implementation:
- Add tests for consumption of aggregated records
- Resuming consumption from an aggregated sub-sequence number
- Add assertions on ShardIteratorType for existing ShardConsumerTest methods
Source code will not be modified, only test code.
All existing and new tests should pass.