tweise opened a new pull request #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer. URL: https://github.com/apache/flink/pull/6427 Ability to override the shard consumer in derived classes, smaller unit of override for shard consumer run loop, consistent use of custom KinesisProxy for discovery and record fetch through factory use. R: @tzulitai @glaksh100 @jgrier @yxu-valleytider
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
