Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4935
One other side note:
Please squash your commits into a single one, with an appropriate commit
message (you can refer to the other commits in the codebase as a starter).
`[FLINK-7945][Metrics&connector]Fix per partition-lag metric lost in kafka
connector` is good, but we would like that to be the commit message also.---
