KafkaProducer takes ProducerRecord as an argument to send(). See the code: https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L298
and a usage example here: https://github.com/gwenshap/kafka-examples/blob/master/SimpleCounter/src/main/java/com/shapira/examples/producer/simplecounter/DemoProducerNewJava.java If you can send Seq<KeyedMessage> instead, it looks like you are still using an older Scala producer. Please check your import statements and which object you are instantiating. Gwen On Sun, Sep 27, 2015 at 10:58 PM, Sharninder <sharnin...@gmail.com> wrote: > Hi Gwen, > > We were using kafka.javaapi.producer.Producer so far and I'm trying to move > the code to use KafkaProducer now but it seems the send api for producer > takes Seq<KeyedMessage> as arguement instead of ProducerRecord as the > documentation for 0.8.2 says: > > > http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html > > Is there an equivalent Java API for 0.8.2 yet or is the older one the most > current? > > -- > Sharninder > > > On Mon, Sep 28, 2015 at 9:15 AM, Gwen Shapira <g...@confluent.io> wrote: > > > KafkaProducer is the most current and full-featured one, and it should be > > used. > > > > The other producers will be deprecated in a release or two, so I > recommend > > not to use them. > > > > On Sun, Sep 27, 2015 at 8:40 PM, Li Tao <ahumbleco...@gmail.com> wrote: > > > > > Hi there, > > > I noticed that there are several producers our there: > > > > > > ** **org.apache.kafka.clients.producer.KafkaProducer<K,V>* > > > ** **kafka.javaapi.producer.Producer* > > > > > > What's the difference between them? Which one should be used? > > > > > > > > > -- > -- > Sharninder >
