Относится ли сохранение журнала kafka к теме __consumer_offsets (тема по умолчанию)?

Question

Мы хотим изменить срок хранения наших тем kafka по умолчанию с 30 дней. Для этого мы использовали следующую команду:

bin/kafka-configs.sh --zookeeper localhost:2181--entity-type topics --entity-name testTopic --alter --add-config retention.ms=2592000000

Но что происходит с темой __consumer_offsets. Эта тема также требует сохранения для обновления?

Answer 1

Время хранения темы __consumer_offsets контролируется параметром offsets.retention.minutes, который является частью конфигурации брокера params.

После того, как группа потребителей потеряет все своипотребителям (т. е. становится пустым), его смещения будут сохраняться в течение этого периода хранения до того, как их выбросят. Для автономных потребителей (с использованием ручного назначения) смещения будут истекать после времени последней фиксации плюс этот период хранения.

Его значение по умолчанию составляло 1440 минут (1 день) до KIP-186, который отметил время хранения до 10800 минут (7 дней) по умолчанию.