After the first consumer is ready, what exactly did u mean by this task? I think the replacement of the counter so that it is based only on Kafka is already done in [AGPUSH-2102|https://issues.jboss.org/browse/AGPUSH-2102]?