В Kafka сообщения удаляются на основе политики хранения, которая задаётся параметрами retention. Сообщения хранятся в топиках определённое время (например, 7 дней) или до достижения максимального размера лога, после чего старые сообщения удаляются автоматически. Удаление не зависит от того, прочитал ли потребитель сообщение.

В RabbitMQ сообщения удаляются после того, как они были подтверждены потребителем (acknowledged). Если сообщение доставлено и подтверждено, оно удаляется из очереди. Также сообщения могут удаляться по истечении TTL (time-to-live) или при переполнении очереди, если настроены соответствующие политики.

В какой момент удаляются сообщения в Kafka и RabbitMQ?