Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-9926

Allow for ShardConsumer override in Kinesis consumer

    XMLWordPrintableJSON

Details

    Description

      There are various reasons why the user may want to override the consumer. Examples are to optimize the run loop or to add additional metrics or logging. Instead of baking the constructor into runFetcher, create a customizable factory method.

       

      Attachments

        Issue Links

          Activity

            People

              thw Thomas Weise
              thw Thomas Weise
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: