Samir Madhavan 2013-04-19, 06:31
-Re: kafka.javaapi.producer.SyncProducer Confusion
Jun Rao 2013-04-22, 03:42
In Producer, we have jmx beans (based on metrics) that report
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?
> 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.
> On Fri, Apr 19, 2013 at 4:15 AM, Itai Frenkel <[EMAIL PROTECTED]>
> > 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
> > -----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
> > 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:
> >>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
> >>Do these classes still exist or am I going wrong somewhere?