detect whether consumer each is active by looking how far behind the latest offsets of the respective kafka partition it is