Thank you Martin On 15 Sep 2016 3:05 am, "Mathieu Fenniak" <[email protected]> wrote:
> Hey Ali, > > If you have auto create turned on, which it sounds like you do, and you're > happy with using the broker's configured partition count and replication > factor, then you can call "partitionsFor(String topic)" on your producer. > This will create the topic without sending a message to it. I'm not sure > it's 100% smart, but I found it to be better than the alternatives I could > find. :-) > > Mathieu > > > On Wed, Sep 14, 2016 at 3:41 PM, Ali Akhtar <[email protected]> wrote: > > > It looks like if I just send a message to a non-existent topic, it is > > created. But this has the downside that the first message of the topic is > > null or otherwise invalid. > > > > Also the partition count can't be specified. > > > > Is there a way to create a topic without needing to post a null message? > Do > > I need to talk to the bash script? > > > > On Wed, Sep 14, 2016 at 8:45 AM, Ali Akhtar <[email protected]> > wrote: > > > > > Using version 0.10.0.1, how can I create kafka topics using the java > > > client / API? > > > > > > Stackoverflow answers describe using kafka.admin.AdminUtils, but this > > > class is not included in the kafka-clients maven dependency. I also > don't > > > see the package kafka.admin in the javadocs: http://kafka.apache. > > > org/0100/javadoc/index.html?org/apache/kafka/clients/produce > > > r/KafkaProducer.html > > > > > > > > > What am I missing? > > > > > > > > >
