Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

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


+
Samir Madhavan 2013-04-19, 06:31
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
> >
> >
> >
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB