simple 08 kafka producer in scala

KafkaTestProducer.sc

package net.dehora.kafka.scala

import java.util.Properties

import kafka.producer.{KeyedMessage, Producer, ProducerConfig}

object KafkaTestProducer {

  def main(args: Array[String]): Unit = {
    val producer = createProducer()
    (0 until 1000).foreach(i => {
      producer.send(new KeyedMessage[String, String]("test", "" + i, "test-" + i))
    })
  }

  def createProducer(): Producer[String, String] = {
    val props = new Properties()
    props.put("metadata.broker.list", "127.0.0.1:9092")
    props.put("serializer.class", "kafka.serializer.StringEncoder")
    props.put("request.required.acks", "1")
    val config = new ProducerConfig(props)
    new Producer[String, String](config)
  }

}