Hi Raghav, Have a look at AdminUtils: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/AdminUtils.scala
– Best regards, Radek Gruchalski ra...@gruchalski.com On November 17, 2016 at 5:58:34 PM, Raghav (raghavas...@gmail.com) wrote: Hi I want to be able to create a topic, if it doesn't exist already ? Is this going to be a two step process of first getting list of topics, and then creating one if it doesn't exist ? Is there an api which takes a topic name and created only if it's not present ? I am doing this stuff in Java. What are the right APIs for these operations ? Thanks. -- Raghav
