ПРИМЕЧАНИЕ: НЕ ДУБЛИКАТ Как получить смещения групп потребителей для раздела в Golang Kafka 10 не отвечает на мой вопрос, это даже не рабочее решение
Я пытаюсь написать функцию go, которая запрашивает kafka для всех смещений групп потребителей по всем темам.
Для этого я надеялся прочитать все сообщения в теме __consumer_offsets и разобрать их.
Однако во всех библиотеках kakfa go, которые я просматривал, я не смог найти способ прочитать все сообщения из __consumer_offsets без их потребления.
(kafka-go либо дает мне возможность читать из одного раздела, либо потребляет сообщений из всей темы)
Итак, мой вопрос, проще говоря: есть ли способ, используя какую-либо библиотеку kafka, получить смещения групп потребителей для всех групп по всем темам?
Если нет, есть ли способ получить смещение для данной темы и идентификатора группы?