Hello, We are on an older kafka (0.8.1) version. While a number of consumers were running, we attempted to delete a few topics using the kafka-topics.sh file (basically want to remove all messages in that topic and restart, since our entities went through some incompatible changes). We noticed logs saying the topic has been queued for deletion. After stopping all processes accessing kafka, we restarted kafka and then our processes. The old topics do not seem to have been deleted (I can still see the log directories corresponding to the topics), and none of the clients are able to either publish or read to the topics that we attempted to delete. Attempting to read gives us the following type of error:
Attempting to access an invalid KafkaTopic ( are you operating on a closed KafkaTopic ?) Attempting to publish gives us a more general type of error: kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) at kafka.producer.Producer.send(Producer.scala:76) How can be get around this issue and start using the topics that we tried to clean up? There may have been better ways to achieve what we wanted, if so please suggest recommendations as well. Thanks Rakesh
