Политика хранения Кафки работает не так, как ожидалось
#apache-kafka Вопрос: Я хотел бы удалить некоторые записи через некоторое время. Для целей тестирования я использовал команду bin/kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --entity-name my-topic-name --add-config retention.ms=1 Что, в моем…