Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5182
Hi @casidiablo, just before merging, I made some refactoring of your PR to
move the metrics reporting business out of the `ShardConsumer`:
https://github.com/apache/flink/commit/14b01be8ec1c00b867aea8dc758c23fe247e05f4.
Let me know if you have any objections with that, if not I'll proceed to
merge soon.---
