producer example

gistfile1.scala

val topic = "urls"
val props = new Properties()
props.put("broker.list", "0:localhost:9092")
props.put("serializer.class", "kafka.serializer.StringEncoder")
val config = new ProducerConfig(props)
val producer = new Producer[String, String](config)

val data = new ProducerData[String, String](topic, href)
producer.send(data)