Реактивная Кафка, не в состоянии отследить смещение лага
Используя Kafka Streams, я могу отслеживать отставание с помощью JMX consumer-fetch-manager-metrics records-lag и предоставлять эти данные, чтобы мы могли отслеживать, отстает ли обработка для данного раздела.
Я надеялся перейти на Reactive Kafka, чтобы мы могли лучше управлять возвращениями брокеру, но когда мы делаем это, у нас появляется ненадежный или недоступный доступ к задержке смещения раздела. Первоначально, сразу после назначения разделов, мы можем увидеть такие значения, как максимальное значение, но ноль для значения задержки записи. В конечном итоге все значения смещения в конечном итоге становятся равными нулю, даже после возврата смещения в Kafka.
Есть ли причина, по которой поведение реактивных потоков kafka и kafka отличается? Есть ли лучший способ получить эти значения в реактивной кафке? Это можно исправить?