как получить доступ и совершить смещения на тему __consumer_offsets темы kafka?

Question

По Кафке Docs

Когда менеджер смещения получает OffsetCommitRequest, он добавляет запрос на специальную уплотненный Кафка тему назвала __consumer_offsets

возможно мы можем получить доступ к нему непосредственно программны? Используя Kafka Tool 1.0 Beta 2, я вижу тему __consumer_offets и множество разделов в ней только с одним разделом, имеющим данные. Не могу понять, как в нем создаются разделы и почему только один раздел имеет данные.

Теперь также как я могу зафиксировать определенный раздел в этом разделе?

Answer 1

Макет и содержание тем __consumer_offsets - это деталь реализации Kafka, и вы не должны пытаться получить к ней доступ напрямую. Вместо этого используйте запросы CustomerMetadata, OffsetCommit и OffsetFetch API, описанные здесь: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI