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

В Apache Kafka длительность хранения сообщений в топиках контролируется следующими основными параметрами конфигурации:

• retention.ms — время хранения сообщений в миллисекундах. По истечении этого времени сообщения удаляются из топика.
• retention.bytes — максимальный размер данных, который может храниться в партиции. Если размер превышен, старые сообщения удаляются.

Эти параметры можно задавать на уровне топика или глобально для брокера. Например, чтобы хранить сообщения 7 дней, можно установить retention.ms=604800000.

Пример настройки retention для топика через команду kafka-topics:

kafka-topics.sh --alter --topic my_topic --config retention.ms=604800000

Таким образом, длительность хранения сообщений регулируется временем и/или размером хранилища.