We encountered a corrupted topic and when we attempt to delete it, it comes back with some unusable defaults. It's really, really annoying. We are shutting down all the kafka brokers, removing the kafka log folder and contents on all nodes, removing the broker topic information from zookeeper and restarting everything, but it continues to happen. We tried creating the topic with one broker down as the topics is only created on one broker but the tool requires all brokers online so that doesn't work. As an aside, creating a topic without all brokers online should be possible... /usr/bin/kafka-topics.sh --zookeeper localhost --create --topic job_processing --partitions 4 --replication-factor 2
Since delete doesn't do what most people would expect and actually delete, we can't delete once online so we are completely stuck. Any suggestions would be appreciated. Thanks, Jason
