Does the issue reproduce consistently? On Tue, Jan 5, 2016 at 10:28 AM, Brenden Cobb <brendenc...@gmail.com> wrote:
> Thanks Alex (and sorry all for the spam) > > I'll give it another go as suggested, however in my tests I was just > using the kafka-topics command and there was definitely a few seconds > between creation/deletion. > > -BC > > On Tue, Jan 5, 2016 at 1:24 PM, Alex Loddengaard <a...@confluent.io> > wrote: > > Hi Brenden, I sent the wrong permalink. Try this: > > > > > http://mail-archives.apache.org/mod_mbox/kafka-users/201512.mbox/%3CCAH7vnfhUQHQcCJ1R3pS_DYn0LvmA8fJtLtvCuvvDboWSqm-NBg%40mail.gmail.com%3E > > > > Alex > > > > On Tue, Jan 5, 2016 at 10:21 AM, Alex Loddengaard <a...@confluent.io> > wrote: > > > >> Hi Brenden, your previous email went through, and you got a response > (that > >> I believe answers your question). See here: > >> > >> > http://mail-archives.apache.org/mod_mbox/kafka-users/201512.mbox/browser > >> > >> Alex > >> > >> On Mon, Jan 4, 2016 at 7:18 PM, Brenden Cobb <brendenc...@gmail.com> > >> wrote: > >> > >>> I might have sent this recently, but was not able to receive mail from > >>> this list (fixed) > >>> --- > >>> > >>> Hello- > >>> > >>> We have a use case where we're trying to create a topic, delete, then > >>> recreate with the same topic name. > >>> > >>> Running into inconsistant results. > >>> > >>> Creating the topic: > >>> /opt/kafka/bin/kafka-topics.sh --create --partitions 3 > >>> --replication-factor 3 --topic test-01 --zookeeper zoo01:2181, > >>> zoo02:2181, zoo03:2181 > >>> > >>> Delete: > >>> /opt/kafka/bin/kafka-topics.sh --delete --topic test-01 --zookeeper > >>> zoo01:2181, zoo02:2181, zoo03:2181 > >>> > >>> Repeat creation. > >>> > >>> The results are inconsistant. Executing the above several times can be > >>> successful, then sporadically we get caught in "topic marked for > >>> deletion" and it does not clear. > >>> > >>> This appears to be a Zookeeper issue of sorts as the logs will show: > >>> [2015-12-30 22:32:32,946] WARN Conditional update of path > >>> /brokers/topics/test-01/partitions/0/state with data > >>> > >>> > {"controller_epoch":21,"leader":2,"version":1,"leader_epoch":1,"isr":[2,0,1]} > >>> and expected version 1 failed due to > >>> org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode > >>> = NoNode for /brokers/topics/test-01/partitions/0/state > >>> (kafka.utils.ZkUtils$) > >>> > >>> In this instance no subdirectories exist beyond /brokers/topics/test-01 > >>> > >>> I'd like to know if this is a common occurrance and why the Zookeeper > >>> node isn't "fully" created as Kafka deletion seems stuck without the > >>> expected node path. > >>> > >>> We are using Kafka 8.2. Purging is also an option (if achievable > >>> programmatically), we just need to make sure there are no messages > >>> left when resuming the producer. > >>> > >>> Appreciate any info/guidance. > >>> > >>> Thanks, > >>> BC > >>> > >> > >> > >> > >> -- > >> *Alex Loddengaard | **Solutions Architect | Confluent* > >> *Download Apache Kafka and Confluent Platform: > www.confluent.io/download > >> <http://www.confluent.io/download>* > >> > > > > > > > > -- > > *Alex Loddengaard | **Solutions Architect | Confluent* > > *Download Apache Kafka and Confluent Platform: www.confluent.io/download > > <http://www.confluent.io/download>* >
