У нас есть Node, а приложения Java используют клиенты Kafka.
В настоящее время требуется получить текущее смещение для каждого раздела для данной темы.
Мы можем видеть детали в Центре управления Confluentи нужно, чтобы эта информация отображалась в нашем приложении.