У нас есть 3 машины кафки, и мы хотим очистить все темы в кафке
как следующее
/usr/hdp/2.6.0.3-8/kafka/bin/kafka-topics.sh --zookeeper master:2181 --alter --topic Topic_Name --config retention.ms=1000
проблема в том, что на двух машинах kafka возникает проблема с тем, что kafka broker на kafka01 / 03 все время перезапускается или kafka broker выключен на kadka01 / 03
поэтому мой вопрос: можем ли мы удалить темы на хорошей машине - kafka02, несмотря на то, что брокер kafka01 / 03 не работает?
секунда - как проверить успех после чистки темы?