[jira] [Created] (FLINK-18515) [Kinesis][EFO] FanOutRecordPublisher and full EFO support

[Shang Yuanchun (Jira)]

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)