Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-17688 Support consuming Kinesis' enhanced fanout for flink-connector-kinesis
  3. FLINK-18483

[Kinesis][EFO] Test coverage improvements for FlinkKinesisConsumer

    XMLWordPrintableJSON

    Details

      Description

      Background

      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.

      Scope

      Improved test coverage for existing Polling consumption implementation:

      1. Add tests for consumption of aggregated records
      2. Resuming consumption from an aggregated sub-sequence number
      3. Add assertions on ShardIteratorType for existing ShardConsumerTest methods

      Source code will not be modified, only test code.

      Result

      All existing and new tests should pass.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                danny.cranmer Danny Cranmer
                Reporter:
                danny.cranmer Danny Cranmer
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: