[jira] [Assigned] (FLINK-18483) [EFO] Test coverage improvements for FlinkKinesisConsumer

["Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tzu-Li (Gordon) Tai reassigned FLINK-18483:
-------------------------------------------

    Assignee: Danny Cranmer

> [EFO] Test coverage improvements for FlinkKinesisConsumer 
> ----------------------------------------------------------
>
>                 Key: FLINK-18483
>                 URL: https://issues.apache.org/jira/browse/FLINK-18483
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Kinesis
>            Reporter: Danny Cranmer
>            Assignee: Danny Cranmer
>            Priority: Major
>
> *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:
>  # 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.
> *Result*
> All existing and new tests should pass.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)