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