Typically, the performance is controlled by how often data is flush to disk in the broker. Try to increase log.flush.interval. See http://incubator.apache.org/kafka/configuration.html for its meaning.
Thanks, Jun On Tue, Apr 17, 2012 at 5:28 AM, <zlai_2...@sina.com> wrote: > Hi， > I implement producer and consumer with java api. But I could not get > the performance according to official document. The official document show > that producer could reach to 250000 nMessages/s and consumer could reach to > 550000 nMessages/s. However, it just reach to 80000 nMessages/s produced > and 40000 nMessages/s consumered. The test is run with a producer, a > consumer, and two brokers. Did anyone have tested the performance with java > client? How can I get the performance as well as offical document. > Thanks! > > > >
