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 >>> >> >> >
signature.asc
Description: OpenPGP digital signature