Kafka Producer in scala Kafka version : 0.10.1.0 scala : 2.11.0

KafkaProducer.scala

import java.util.Properties

import com.gta.config.GlobalVariables
import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}
import scala.util.Random

object KafkaProducer {

  def produceToKafka(message : String): Unit ={

    val topic = "notifications"
    val rnd = new Random()
    val props = new Properties()
    props.put("bootstrap.servers", GlobalVariables.KAFKA_BROKER)
    props.put("client.id", "notificationProduce")
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")


    val producer = new KafkaProducer[String, String](props)
    val t = System.currentTimeMillis()
    val data = new ProducerRecord[String, String](topic, message)

    //async
    //producer.send(data, (m,e) => {})
    //sync
    producer.send(data)
    producer.close()
  }
}