You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "Matthias J. Sax" <ma...@confluent.io> on 2018/08/01 01:22:53 UTC
Re: Creating and deleting Kafka Topics in Scala App
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
>
Re: Creating and deleting Kafka Topics in Scala App
Posted by Pulkit Manchanda <pu...@gmail.com>.
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 <ma...@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 <ma...@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
> >>>
> >>
> >>
> >
>
>
Re: Creating and deleting Kafka Topics in Scala App
Posted by "Matthias J. Sax" <ma...@confluent.io>.
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 <ma...@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
>>>
>>
>>
>
Re: Creating and deleting Kafka Topics in Scala App
Posted by Pulkit Manchanda <pu...@gmail.com>.
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 <ma...@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
> >
>
>