kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pulkit Manchanda <pulkit....@gmail.com>
Subject Re: Creating and deleting Kafka Topics in Scala App
Date Thu, 02 Aug 2018 18:45:21 GMT
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 <matthias@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 <matthias@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
> >>>
> >>
> >>
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message