Я хочу знать текущее смещение FlinkKafkaConsumer010 в режиме реального времени для мониторинга.В режиме, где включена контрольная точка, в официальном документе говорится, что этот коммит будет отправлен только с отправкой контрольной точки, поэтому я не могу получить нужный эффект в реальном времени.Есть ли какая-то информация, которую я могу получить от Кафки?Я использовал kafka.admin для получения текущего смещения, но это зависит от интервала контрольных точек.Даже если источник всегда используется, он не будет обновлять текущее смещение, если контрольная точка не завершена.Jmx Кафки имеет индикатор BytesOutPerSec для темы.Кажется, что совершить поведение потребителя не имеет значения.Есть ли аналогичный способ получить текущее смещение от темы или брокера?Или есть другой способ?
Спасибо за помощь.
