Probably important to read and understand these enhancements coming in 0.11
https://cwiki.apache.org/confluence/display/KAFKA/KIP-117%3A+Add+a+public+AdminClient+API+for+Kafka+admin+operations -hans /** * Hans Jespersen, Principal Systems Engineer, Confluent Inc. * h...@confluent.io (650)924-2670 */ On Tue, May 30, 2017 at 3:50 PM, Mohammed Manna <manme...@gmail.com> wrote: > 1) For issue no. 1 I think you might find the AdminUtils useful This link > <https://stackoverflow.com/questions/16946778/how-can-we- > create-a-topic-in-kafka-from-the-ide-using-api> > should > help you understand. > > I haven't got around using ACL for Kafka yet (as I am still doing PoC > myself) - so probably some other power user can chime in? > > KR, > > On 30 May 2017 at 23:35, Raghav <raghavas...@gmail.com> wrote: > > > Hi > > > > I want to know if there are Java APIs for the following. I want to be > able > > to do these things programmatically in our Kafka cluster. Using command > > line tools seems a bit hacky. Please advise the right way to do, and any > > pointers to Library in Java, Python or Go. > > > > 1. Creating topic with a given replication and partition. > > 2. Push ACLs into Kafka Cluster > > 3. Get existing ACL info from Kafka Cluster > > > > Thanks. > > > > Raghav > > >
