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
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
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
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
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
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
