Hi Jason, You do want to wait for the next release as a lot of stability fixes are going into that.
Tim On Thu, Aug 7, 2014 at 10:25 AM, Gwen Shapira <gshap...@cloudera.com> wrote: > Looking at the delete topic patch, it looks like there were > significant modifications in the controller code to support that, so I > think you are out of luck. > > (https://reviews.apache.org/r/20745) > > On Thu, Aug 7, 2014 at 8:18 AM, Jason Rosenberg <j...@squareup.com> wrote: >> Since the deletion stuff is now in trunk, would be compatible to issue the >> command from a jar built from trunk, against a running 0.8.1.1 cluster? Or >> does the cluster also have to be running trunk? (I'm guessing it does :)). >> >> I have some topics I'd like to delete, but don't want to wait for 0.8.2 >> (but will probably have to, I'm guessing). >> >> Jason >> >> >> On Thu, Aug 7, 2014 at 2:53 AM, Timothy Chen <tnac...@gmail.com> wrote: >> >>> Hi Gwen, >>> >>> That is a very confusing error message for sure, feel free to file a >>> jira for both the experience cases. >>> >>> But in general how delete topic works is that it creates a entry in >>> the delete_topic zk path, and the leader has a delete topic thread >>> that watches that path and starts the topic deletion once it receives >>> the message. It then requires rounds of coordination among all the >>> brokers that has partitions for the topic to delete all the >>> partitions, then finally delete the topic from zk. >>> >>> Therefore once the deletion finishes it will also deleted from zk. The >>> topic command can definitely however join the topic list with the >>> delete topic list and mark the ones being deleted with a special >>> status. >>> >>> Tim >>> >>> On Wed, Aug 6, 2014 at 11:20 PM, Gwen Shapira <gshap...@cloudera.com> >>> wrote: >>> > Hi Timothy, >>> > >>> > While we are on the subject, few questions/comments (based on the >>> > trunk implementation of delete topic command): >>> > >>> > * After deleting a topic, I still see it when listing topics. Is the >>> > expected behavior? Should it disappear after some time? >>> > * When does the actual deletion gets triggered? >>> > * If I try to delete a topic twice I get a pretty confusing exception >>> > (Node exists from zkclient). It will be nice to catch this and say >>> > "Topic is being deleted" or something to this effect. >>> > * Even nicer if list topics command will mark topics as "being deleted". >>> > >>> > I'll probably open a separate Jira for the "nice" behavior, but >>> > interested in hearing your thoughts. >>> > >>> > Gwen >>> > >>> > On Wed, Aug 6, 2014 at 11:01 PM, Timothy Chen <tnac...@gmail.com> wrote: >>> >> Is this the latest master? I've added the delete option in trunk, but >>> >> it's not in any release yet. >>> >> >>> >> We used to have the delete option flag but I believe we removed it >>> >> that's why the documentation difference. >>> >> >>> >> Tim >>> >> >>> >> On Wed, Aug 6, 2014 at 10:53 PM, Shlomi Hazan <shl...@viber.com> wrote: >>> >>> if the answer is pointing out the 'chroot', as a word, it makes no >>> >>> difference. the result is the same: >>> >>> >>> >>> kafka/bin/kafka-topics.sh --zookeeper localhost:2181/chroot --delete >>> >>> --topic topic-3 >>> >>> >>> >>> gives the same: >>> >>> >>> >>> "Command must include exactly one action: --list, --describe, --create >>> or >>> >>> --alter..." >>> >>> >>> >>> or should I write something instead of "chroot"? >>> >>> >>> >>> >>> >>> >>> >>> On Wed, Jun 18, 2014 at 2:06 PM, Shlomi Hazan <shl...@viber.com> >>> wrote: >>> >>> >>> >>>> Hi, >>> >>>> >>> >>>> Doing some evaluation testing, and accidently create a queue with >>> wrong >>> >>>> replication factor. >>> >>>> >>> >>>> Trying to delete as in: >>> >>>> >>> >>>> kafka_2.10-0.8.1.1/bin/kafka-topics.sh --zookeeper localhost:2181 >>> --delete >>> >>>> --topic replicated-topic >>> >>>> >>> >>>> Yeilded: >>> >>>> >>> >>>> Command must include exactly one action: --list, --describe, --create >>> or >>> >>>> –alter >>> >>>> >>> >>>> Event though this page (https://kafka.apache.org/documentation.html) >>> says: >>> >>>> >>> >>>> >>> >>>> >>> >>>> And finally deleting a topic: >>> >>>> >>> >>>> > bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete >>> --topic my_topic_name >>> >>>> >>> >>>> WARNING: Delete topic functionality is beta in 0.8.1. Please report >>> any >>> >>>> bugs that you encounter on themailing list <%20us...@kafka.apache.org> >>> or >>> >>>> JIRA <https://issues.apache.org/jira/browse/KAFKA>. >>> >>>> >>> >>>> Kafka does not currently support reducing the number of partitions >>> for a >>> >>>> topic or changing the replication factor. >>> >>>> >>> >>>> What should I do? >>> >>>> >>> >>>> Shlomi >>> >>>> >>>
