Удаляются ли сообщения в Kafka

Сообщения в Kafka не удаляются автоматически по умолчанию. Они хранятся на диске в течение заданного времени (по умолчанию 7 дней) или до достижения лимита размера топика.

Как управлять удалением:

1. По времени (log.retention.hours):
   properties

   Копировать

   log.retention.hours=168  // 7 дней (дефолт)

2. По размеру (log.retention.bytes):
   properties

   Копировать

   log.retention.bytes=1073741824  // 1 ГБ

3. Компактификация (для ключевых сообщений):
   properties

   Копировать

   cleanup.policy=compact

   Сохраняет последнее значение для каждого ключа.

Можно принудительно удалить через kafka-delete-records, но это редко используется.