In 0.7.x and 0.8.x, there is no way for the async producer to notify the
client through a callback. However, this is being planned for the upcoming
0.9 release. You can take a look at the proposed API here -
https://cwiki.apache.org/confluence/display/KAFKA/Client+Rewrite#ClientRewrite-ProposedProd
Hi guys, i was wondering what will be the best way to provide delivery
guarantee service by using an async producer in kafka 0.7.2.
I want my service to be ready to support kafka downtimes for at least 12
hours so i would like to aggregate logs locally into some failover spool
and then rerun them w