What version of kafka you are on? There are issues with delete topic until I guess kafka 0.10.1.0
You may be hitting this issue… https://issues.apache.org/jira/browse/KAFKA-2231 <https://issues.apache.org/jira/browse/KAFKA-2231> Thanks Zakee > On Apr 6, 2017, at 11:20 AM, Adrian McCague <adrian.mcca...@zopa.com> wrote: > > Hi Sachin, > > I am told with confidence that the setting is present in server.properties (I > do not have access to the server). > > I have used delete before without issue, and attempted to use it when the > setting is false and the behaviour is different. I'm certain that running the > command multiple times always shows the warning, that without the setting > being true, the command has no effect. In this case it confirms that the > topic is marked for deletion. > > Thanks > Adrian > > -----Original Message----- > From: Sachin Mittal [mailto:sjmit...@gmail.com] > Sent: 06 April 2017 19:05 > To: users@kafka.apache.org > Subject: Re: Topic deletion > > Do you have delete.topic.enable=true uncommented or present in > server.properties > > On Thu, Apr 6, 2017 at 11:03 PM, Adrian McCague <adrian.mcca...@zopa.com> > wrote: > >> Hi all, >> >> I am trying to understand topic deletion in kafka, there appears to be >> very little documentation or answers on how this works. Typically they >> just say to turn on the feature on the broker (in my case it is). >> >> I executed: >> Kafka-topics.bat -delete -zookeeper keeperhere -topic mytopic >> >> Running this again yields: >> Topic mytopic is already marked for deletion. >> >> --describe yields: >> Topic: mytopic PartitionCount:6 ReplicationFactor:3 Configs: >> retention.ms=0 >> Topic: mytopic Partition: 0 Leader: -1 Replicas: >> 1006,1001,1005 Isr: >> Topic mytopic Partition: 1 Leader: -1 Replicas: >> 1001,1005,1003 Isr: >> Topic: mytopic Partition: 2 Leader: -1 Replicas: >> 1005,1003,1004 Isr: >> Topic: mytopic Partition: 3 Leader: -1 Replicas: >> 1003,1004,1007 Isr: >> Topic: mytopic Partition: 4 Leader: -1 Replicas: >> 1004,1007,1006 Isr: >> Topic: mytopic Partition: 5 Leader: -1 Replicas: >> 1007,1006,1001 Isr: >> >> You can see that the deletion mark has meant that the Leader is -1. >> Also I read somewhere that retention needs to be set to something low >> to trigger the deletion, hence the config of retention.ms=0 >> >> Consumers (or streams in my case) no longer see the topic: >> org.apache.kafka.streams.errors.TopologyBuilderException: Invalid >> topology building: stream-thread [StreamThread-1] Topic not found: >> mytopic >> >> And I can't create a new topic in its place: >> [2017-04-06 18:26:00,702] ERROR >> org.apache.kafka.common.errors.TopicExistsException: >> Topic 'mytopic' already exists. (kafka.admin.TopicCommand$) >> >> I am a little lost as to where to go next, could someone explain how >> topic deletion is actually applied when a topic is 'marked' for >> deletion as that may help trigger it. >> >> Thanks! >> Adrian >> >> ____________________________________________________________ Affordable Wireless Plans Set up is easy. Get online in minutes. Starting at only $14.95 per month! www.netzero.net?refcd=nzmem0216
