The new producer in 0.8.2 is considered stable, although it's relatively new. Compared with the old producer, it has the following features.
1. Use non-blocking socket to send requests to the broker. So uses fewer threads and have better throughput. 2. Bound the memory consumption. 3. Support a callback when sending a request asynchronously. 4. Returns the offset for each produced message. You can look at the example in the java doc. http://www.trieuvan.com/apache/kafka/0.8.2-beta/java-doc/org/apache/kafka/clients/producer/KafkaProducer.html Thanks, Jun On Mon, Nov 17, 2014 at 4:46 AM, Shlomi Hazan <shl...@viber.com> wrote: > Hi, > I need to make a choice and I can't get a full picture on the differences > between the two. > E.g.: > Are both producers async capable to the same extent? > Is the new producer stable for production? > Is there some usage example for the new producer? > What are the tradeoffs using one or another? > 10x, > Shlomi >
