Hi Matthias, Thanks for the response. I found the issue, actually my streaming job was still writing to the topic even after I deleted it. And my brokerhad default setting of auto.create.topic. So the topic was created again.
Thanks Pulkit On Wed, Aug 1, 2018 at 12:57 PM, Matthias J. Sax <matth...@confluent.io> wrote: > Not sure. Anything interesting in the logs? Maybe you need to enable DEBUG. > > As an alternative, you might ask a question on the Github page providing > the example code. > > > -Matthias > > On 8/1/18 7:11 AM, Pulkit Manchanda wrote: > > Hi Matthias, > > > > Thanks for the reply, I had already tried that. But it doesn't work > either. > > > > Pulkit > > > > On Tue, Jul 31, 2018 at 9:22 PM, Matthias J. Sax <matth...@confluent.io> > > wrote: > > > >> Is `delete.topic.enable` set to `true`? It's a broker configuration. > >> > >> > >> -Matthias > >> > >> On 7/31/18 8:57 AM, Pulkit Manchanda wrote: > >>> HI All, > >>> > >>> I am want to create and delete Kafka topics on runtime in my > Application. > >>> I followed few projects on GitHub like > >>> https://github.com/simplesteph/kafka-0.11- > examples/blob/master/src/main/ > >> scala/au/com/simplesteph/kafka/kafka0_11/demo/ > KafkaAdminClientDemo.scala > >>> > >>> But to no avail. The code runs smooth but I don't see any topics on the > >>> server. > >>> > >>> Does anyone have references to the working code. > >>> > >>> Thanks > >>> Pulkit > >>> > >> > >> > > > >
