Как почистить партиции в кафке __consumer_offsets*?

Question

[Serg445]

Добрый день!
Используем apache kafka версии
2.1.0 (Commit:809be928f1ae004e)

для контроля размера партиции устанавливаю параметры retention.ms, retention.bytes , благодаря им топики сервисов чистятся нормально.
Но при этом топик _consumer_offset не очищается, на текущий момент одна из партиций в нем занимает 6 Гб.
Чем ее можно почистить ?

ЗЫ:
используется тэг Linux и Apache, так как нет тэга Apache Kafka или просто Kafka

Comments

[CityCat4]

вопрос к тегу linux имеет только то отношение, что апач под ним работает.

[Serg445]

CityCat4, пытался добавить тэг kafka/apache kafka , но система говорит что такого тэга нет, добавьте существующий тэг.

[CityCat4]

Serg445, можно:
- добавить тег apache - это все же сужает область
- написать в саппорт с просьбой добавить новый тег (не факт, что добавят, но что бы и не попробовать?)

Answer 1

[Vitaly Karasik]

Во-первых, советую обновить версию.

"The __consumer_offsets topic retention time is controlled by the offsets.retention.minutes parameter, which is part of the broker configuration params." - https://stackoverflow.com/questions/58180608/does-...