Sorry, you're correct. Looks like a silly mistake on my side. I'll check my
imports
--
Sharninder
On Mon, Sep 28, 2015 at 6:24 PM, Gwen Shapira wrote:
> KafkaProducer takes ProducerRecord as an argument to send().
>
> See the code:
>
> https://github.com/apache/kafka/blob/trunk/clients/src/mai
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/
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 as arguement instead of ProducerRecord as the
documentation for 0.8.2 says:
http://kafka.apache.org/082/javadoc/org/apache/kafka/
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 wrote:
> Hi there,
> I noticed that there are several producers our there:
>
> **
Hi there,
I noticed that there are several producers our there:
** **org.apache.kafka.clients.producer.KafkaProducer*
** **kafka.javaapi.producer.Producer*
What's the difference between them? Which one should be used?
