apache
[FLINK-31980] Implement support for EFO in Kinesis consumer
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
Hi, EFO is very important for using the New SouceAPI. Do you plan to finish this PR?
@Sunninsky Hey! We are currently working on implementing EFO support for the new source connector. Estimate maybe end of the quarter?
@Sunninsky Hey! We are currently working on implementing EFO support for the new source connector. Estimate maybe end of the quarter?
That's very cool, thank you.