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