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?
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.
On Fri, Apr 19, 2013 at 4:15 AM, Itai Frenkel <[EMAIL PROTECTED]> wrote:
In Producer, we have jmx beans (based on metrics) that report byte/message/request rate.
Jun On Fri, Apr 19, 2013 at 9:54 AM, Drew Daugherty < [EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext