Свойство "cleanup.policy" является частью конфигурации Apache Kafka и определяет, какие сообщения в целом подлежат удалению из лога темы.
Значение свойства "cleanup.policy" можно изменить путем отредактирования файла настроек сервера Kafka - server.properties.
Чтобы внести исправления, нужно следовать этим шагам:
1. Откройте файл server.properties, расположенный в папке конфигурации Kafka.
2. Найдите свойство "cleanup.policy".
3. Измените его значение на требуемое. Например, включите удаление сообщений старше определенного времени, установив значение "cleanup.policy=delete".
4. Сохраните файл server.properties.
После внесения этих изменений необходимо перезапустить сервер Kafka, чтобы изменения вступили в силу.
