Wrong args for KeyedMessage constructor
Wrong args for KeyedMessage constructor

Please check the following code from kafka repo
https://github.com/apache/kafka/blob/0.8.1/core/src/main/scala/kafka/producer/KeyedMessage.scala
the constructor of KeyedMessage takes topic,message or topic,key,message as arguments
kali786516/scala-kafka,stealthly/scala-kafka,gabhi/scala-kafka,elodina/scala-kafka,chris-dtv/scala-kafka