https://github.com/grafana/metrictank/blob/master/input/kafkamdm/kafkamdm.go#L312-L326

If consuming a message blocks (eg due to the index being locked or writeQueue is full), then we dont consume from the ticker until after we become unblocked. This can leave us with long periods with no insight into how far behind an MT node is falling behind.