flink-connector-aws icon indicating copy to clipboard operation
flink-connector-aws copied to clipboard

Published 20 hours ago • verified publisher icon apache

[FLINK-31980] Implement support for EFO in Kinesis consumer

Open hlteoh37 opened this issue 1 year ago • 3 comments

Purpose of the change

Implement support for EFO in the new KDS source

Verifying this change

This change added tests and can be verified as follows:

  • Added unit tests
  • Manually verified by running the Kinesis connector on a local Flink cluster.

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)

  • [ ] Dependencies have been added or upgraded
  • [ ] Public API has been changed (Public API is any class annotated with @Public(Evolving))
  • [ ] Serializers have been changed
  • [x] New feature has been introduced
    • If yes, how is this documented? Documented as part of https://issues.apache.org/jira/browse/FLINK-31989

hlteoh37 avatar Jun 12 '23 18:06 hlteoh37