Danny Cranmer created FLINK-18515:
-------------------------------------
Summary: [Kinesis][EFO] FanOutRecordPublisher and full EFO support
Key: FLINK-18515
URL: https://issues.apache.org/jira/browse/FLINK-18515
Project: Flink
Issue Type: Sub-task
Reporter: Danny Cranmer
*Background*
In order to utilise an EFO subscription a consumer must register and acquire a
ConsumerARN. Subsequently the ConsumerARN can be used to request a subscription
and start receiving data. The user application will determine whether to use
Polling or FanOut consumption via the connector properties.
*Scope*
Add EFO support by implementing the following four items:
* Connector Configuration
* Stream Consumer Registration
* Fan Out Record Consumption ({{FanOutRecordPublisher}}
* Stream Consumer De-registration
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
