kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sharninder <sharnin...@gmail.com>
Subject Re: which producer should be used
Date Mon, 28 Sep 2015 14:23:16 GMT
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 <gwen@confluent.io> wrote:

> 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 <sharninder@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 <gwen@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 <ahumblecoder@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
> >
>



-- 
--
Sharninder

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message