Python tool that allows you to constantly monitor LAG value for each partition/topic/group. The output is in JSON format and contains datatime.