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 >
