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

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

                Dates

                • Created:
                  Updated:
                  Resolved: