Details

      Description

      Background
      The user application will determine whether to use Polling or FanOut consumption via the connector properties. EFO consumption will use SubscribeToShard to retrieve data from KDS.

      Scope

      Add Fan Out Publisher to Flink Kinesis Connector, including:

      • FanOutRecordPublisher
      • FanOutRecordPublisherFactory
      • SubscribeToShard within the KinesisProxyV2
      • Metric logging

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                danny.cranmer Danny Cranmer
                Reporter:
                danny.cranmer Danny Cranmer
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: