У нас есть 3 машины кафки версии - 0.10.0.2.6
Мы хотим удалить все файлы данных из всех тем kafka (полностью удалить все данные)
Интерфейс командной строки для этого действия должен быть (должен запускаться с сервера зоопарка)
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic1 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic2 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic3 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic4 --config retention.ms=1000
Поскольку мы Временно обновляем время удержания в теме до одной секунды (1000 мс)
Тогда как вернуть прежнее оригинальное удержание!
Примечание - log.retention.hours = 168 (из графического интерфейса Ambari), и это исходное значение
Так как же вернуть исходное значение (168 часов) по всем темам? после чистки всех тем?
Вы запускаете ту же команду, но устанавливаете время хранения на 168 часов в миллисекундах.