Some Utility Function for programming Kafka in Scala

KafkaUtility.scala

//Create new Kafka topic 
def createTopic(topic: String, client: AdminClient) = {
   val newTopic = new NewTopic(topic, 6, 3.toShort)

     try {
       val topic = client.createTopics(List(newTopic).asJavaCollection)
       topic.values().get(topic).get() //Not Scala design here
         } catch {
           case e: InterruptedException with ExecutionException=> {
             case d: TopicExistsException => throw new RuntimeException(e.getMessage, e)
             case _ => println(s"$topic you are trying to create already exists")
           }
     }
 }