Sure — take a look at the kafka unit tests as well as admin.AdminUtils , e.g.:
import kafka.admin.AdminUtils
AdminUtils.createTopic(zkClient, topicNameString, 10, 1)
Best Regards,
-Jonathan
On Oct 13, 2014, at 9:58 AM, hsy...@gmail.com wrote:
> Hi guys,
>
> Besides TopicCommand, which I believe is not provided to create topic
> programmatically, is there any other way to automate creating topic in
> code? Thanks!
>
> Best,
> Siyuan
