Hi Joe,

We're doing a similar thing that you're looking for with some of our app
nodes. We use the kafka.admin.AdminTools and its
topicExists()/createTopic() methods. Some additional code (e.g. Kafka
context check/creation) might be needed for dev/test environments if you're
using a specific Kafka context instead of the root.

-Timo

On 20 January 2016 at 23:14, Joe San <codeintheo...@gmail.com> wrote:

> I doubt that might be enough. Could you tell me if the
> auto.create.topics.enable satisfies the following requirement?
>
> 1. I want to create a topic with a specific name
> 2. If I restart the producer client, if the topic with that name already
> exists, it should do nothing and use the topic as is
> 3. Upon producer restart, if the topic already exists, and if the topic has
> un consumed messages, it should not be deleted
>
> Thanks and Regards,
> Joe
>
> On Wed, Jan 20, 2016 at 2:11 PM, Franco Giacosa <fgiac...@gmail.com>
> wrote:
>
> > Hi Joe,
> >
> > There is an option in the producer called auto.create.topics.enable, so
> the
> > producer can just start sending data to a topic and the topic will be
> > created with the default values.
> >
> >
> >
> > 2016-01-20 13:19 GMT+01:00 Joe San <codeintheo...@gmail.com>:
> >
> > > Kafka Users,
> > >
> > > How can I create a kafka topic programatically?
> > >
> > > I would like to create the topics when I initialize my application. It
> > > should also be in such a way that if the topic already exists, the
> > > initialization code should do nothing!
> > >
> > > Thanks and Regards,
> > > Joe
> > >
> >
>

Reply via email to