On 05/01/2014 07:22 PM, Christian Csar wrote: > I'm looking at using the java producer api for 0.8.1 and I'm slightly > confused by this passage from section 4.4 of > https://kafka.apache.org/documentation.html#theproducer > "Note that as of Kafka 0.8.1 the async producer does not have a > callback, which could be used to register handlers to catch send errors. > Adding such callback functionality is proposed for Kafka 0.9, see > [Proposed Producer > API](https://cwiki.apache.org/confluence/display/KAFKA/Client+Rewrite#ClientRewrite-ProposedProducerAPI)." > > org.apache.kafka.clients.producer.KafkaProducer in 0.8.1 appears to have > public Future<RecordMetadata> send(ProducerRecord record, Callback > callback) which looks like the mentioned callback. > > How do the callbacks with the async producer? Is it as described in the > comment on the send method (see > https://github.com/apache/kafka/blob/0.8.1/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L151 > for reference)? > > Looking around it seems plausible the language in the documentation > might refer to a separate sort of callback that existed in 0.7 but not > 0.8. In our use case we have something useful to do if we can detect > messages failing to be sent. > > Christian >
It appears that I was looking at the Java client rather than the Scala java api referenced by the documentation https://github.com/apache/kafka/blob/0.8.1/core/src/main/scala/kafka/javaapi/producer/Producer.scala Are both of these currently suited for use from java and still supported? Given the support for callbacks in the event of failure I am inclined to use the Java one despite the currently limited support for specifying partitioners (though it supports specifying the partition) or encoders. Any guidance on this would be appreciated. Christian
signature.asc
Description: OpenPGP digital signature
