Creating and deleting Kafka Topics in Scala App

[Pulkit Manchanda]

HI All,

I am want to create and delete Kafka topics on runtime in my Application.
I followed few projects on GitHub like
https://github.com/simplesteph/kafka-0.11-examples/blob/master/src/main/scala/au/com/simplesteph/kafka/kafka0_11/demo/KafkaAdminClientDemo.scala

But to no avail. The code runs smooth but I don't see any topics on the
server.

Does anyone have references to the working code.

Thanks
Pulkit