Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> kafka.javaapi.producer.SyncProducer Confusion


Copy link to this message
-
Re: kafka.javaapi.producer.SyncProducer Confusion
In Producer, we have jmx beans (based on metrics) that report
byte/message/request rate.

Thanks,

Jun
On Fri, Apr 19, 2013 at 9:54 AM, Drew Daugherty <
[EMAIL PROTECTED]> wrote:

> I would second this request. We would like to gather metrics on the
> SyncProducer (bytes in/out, messages in/out, time spent in
> preparing/sending messages, etc.) when we are sending asynchronously.  Or
> would you recommend something like Scala actors as a better solution?
>
> -drew
> ________________________________________
> From: Neha Narkhede [[EMAIL PROTECTED]]
> Sent: Friday, April 19, 2013 10:20 AM
> To: [EMAIL PROTECTED]
> Subject: Re: kafka.javaapi.producer.SyncProducer Confusion
>
> In 0.8, the producer API does not have callbacks to notify you of the
> status of the messages. However, I think we want to rethink the client
> APIs for 0.9. Let us know if you have feedback.
>
> Thanks,
> Neha
>
> On Fri, Apr 19, 2013 at 4:15 AM, Itai Frenkel <[EMAIL PROTECTED]>
> wrote:
> > Could you give some pointers (or test case perhaps) how to detect that a
> message was sent successfully to the broker, when sending the data
> asynchronously?
> >
> > -----Original Message-----
> > From: Swapnil Ghike [mailto:[EMAIL PROTECTED]]
> > Sent: Friday, April 19, 2013 10:24 AM
> > To: [EMAIL PROTECTED]
> > Subject: Re: kafka.javaapi.producer.SyncProducer Confusion
> >
> > Hi Samir,
> >
> > In 0.8, we don't have SyncProducer as a public api. You can use
> kafka.javaapi.producer.Producer to send the data synchronously or
> asynchronously.
> >
> > The quick start page is outdated, and we plan to update a few pages soon
> (before the 0.8 BETA release). In fact, we would love to have contribution
> from the community for updating the website. :)
> >
> > Thanks,
> > Swapnil
> >
> >
> >
> > On 4/18/13 11:30 PM, "Samir Madhavan"
> > <[EMAIL PROTECTED]> wrote:
> >
> >>Hi,
> >>
> >>I'm using kafka-0.8 Snapshot. In the quick start, there is an example
> >>producer code in which SyncProducer class has been mentioned but when I
> >>checked the kafka.javaapi.producer, there is only Producer class and no
> >>SyncProducer or ProducerData class.
> >>
> >>I went through the apache github source code and also the svn trunk
> >>code but these classes are not there.
> >>
> >>In the api documentation of apache kafka site, these classes have been
> >>shown.
> >>
> >>Do these classes still exist or am I going wrong somewhere?
> >>
> >>Regards,
> >>Samir
> >
> >
> >
>