XMLWordPrintableJSON

    Details

      Description

      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.

      Scope

      • Implement stream registration and deregistration in the KinesisV2Proxy/KinesisV2ProxyInterface
      • Invoke registration based on the specified strategy:
        • LAZY: At start-up within KinesisDataFetcher
        • EAGER: Within FlinkKinesisConsumer constructor (add the consumer ARN to config)
        • NONE: Disabled
      • Invoke deregistration based on the specified strategy:
        • LAZY|EAGER: During tear-down within KinesisDataFetcher
        • NONE: Disabled

        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: