KafkaSource watermarkLag metrics per topic per partition

[Alexey Trenikhun]

Hello,
Is there way to configure Flink to expose watermarLag metric per topic per 
partition? I think it could be useful to detect data skew between partitions

Thanks,
Alexey