Could you do a get on /admin/deleted_topics and see if its cversion changes after issuing the delete topic command? This will tell us whether the path /admin/deleted_topics//mytopic is actually created or not. Anything in the controller log that indicates a delete topic event is fired?
Thanks, Jun On Sun, Jan 25, 2015 at 9:55 PM, Jason Rosenberg <j...@squareup.com> wrote: > yes > > On Mon, Jan 26, 2015 at 12:18 AM, Jun Rao <j...@confluent.io> wrote: > > > Do you have delete.topic.enable turned on in all brokers? > > > > Thanks, > > > > Jun > > > > On Sun, Jan 25, 2015 at 7:56 PM, Jason Rosenberg <j...@squareup.com> > wrote: > > > > > So far, I have been unable to get delete topic to work, with release > > > candidate 2 for 0.8.2. > > > > > > It worked ok when I ran it in the debugger locally, on a single node > > > instance. But when I run it in our staging environment, it is not > > > successfully even marking the topic for delete, for some reason. > > > > > > I am setting delete.topic.enable to true (and see the confirmation of > > this > > > in the startup logs, e.g.): > > > > > > INFO [main] utils.VerifiableProperties - Property delete.topic.enable > > > is overridden to true > > > > > > I run this command: > > > > > > java -cp app.jar kafka.admin.TopicCommand --zookeeper > > > myzkconnect:12345/mynamespace --delete --topic mytopic > > > > > > log4j:WARN No appenders could be found for logger > > > (org.I0Itec.zkclient.ZkConnection). > > > log4j:WARN Please initialize the log4j system properly. > > > log4j:WARN No appenders could be found for logger > > > (org.I0Itec.zkclient.ZkEventThread). > > > log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig > > > for more info. > > > log4j:WARN Please initialize the log4j system properly. > > > log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig > > > for more info. > > > Topic mytopic is marked for deletion. > > > Note: This will have no impact if delete.topic.enable is not set to > true. > > > > > > I then do a —list which should at least show the topic marked for > > deletion: > > > > > > java -cp app.jar kafka.admin.TopicCommand --zookeeper > > > myzkconnect:12345/mynamespace --list --topic mytopic > > > > > > log4j:WARN No appenders could be found for logger > > > (org.I0Itec.zkclient.ZkConnection). > > > log4j:WARN No appenders could be found for logger > > > (org.I0Itec.zkclient.ZkEventThread). > > > log4j:WARN Please initialize the log4j system properly. > > > log4j:WARN Please initialize the log4j system properly. > > > log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig > > > for more info. > > > log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig > > > for more info. > > > mytopic > > > > > > Note, it doesn’t list it as ‘marked for deletion’. Furthermore, waiting > > > multiple hours still doesn’t result in the topic being deleted. > > > > > > The topic has 1 partition, 2 replicas, and no data stored. > > > > > > In zookeeper, the /admin/deleted_topics/ path is empty. > > > > > > The zookeeper code looks pretty straightforward, but for some reason is > > not > > > writing the deleted_topics path. We are running zookeeper 3.4.6. > > > > > > Thoughts? > > > > > > Jason > > > > > > > > >
