THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Page properties |
---|
...
|
...
|
...
Table of Contents |
---|
Motivation
...
Properties will be validated, and de-/registration will be performed based on the supplied configuration:
flink.stream.efo.registrar | flink.stream.efo.consumerarn.<stream-name> | Registration | Deregistration |
lazy | Not required | task startup | task tear-down |
eager | Not required | FlinkKinesisConsumer constructor | task tear-down |
none | Required | none | none |
Stream Consumer Registration
...
- [Documentation] FLIP created, reviewed and approved
- [Jira sub task/Pull Request] Improved test coverage for existing Polling consumption implementation
- [Jira sub task/Pull Request] Refactor existing code support
RecordPublisher
. A singlePollingRecordPubisher
will be included. Behaviour of consumer will be unchanged. Include relevant documentation. - [Jira sub task/Pull Request] Add AWS SDK v2.x dependency along with FanOutKinesisProxy
- [Jira sub task/Pull Request] Configuration validation and deserialisation for Fan Out consumers
- [Jira sub task/Pull Request] Stream consumer registration and de-registration strategies
- [Jira sub task/Pull Request] Add
FanOutRecordPublisher
to add EFO support. Include relevant documentation and end to end tests - [Sample Applications] Publish sample applications and additional documentation.
...