(Please correct me if I am wrong.) Based on TestEndToEndLatency( https://github.com/apache/kafka/blob/trunk/core/src/test/scala/kafka/tools/TestEndToEndLatency.scala), consumer_fetch_max_wait corresponds to fetch.wait.max.ms in consumer config( http://kafka.apache.org/documentation.html#consumerconfigs). The default value listed at document is 100(ms).
To add java heap space to jvm, put -Xmx$Size(max heap size) for your jvm option. On Wed, Jul 15, 2015 at 12:29 AM, Yuheng Du <yuheng.du.h...@gmail.com> wrote: > Tao, > > Thanks. The example on https://gist.github.com/jkreps/c7ddb4041ef62a900e6c > is outdated already. The error message shows: > > USAGE: java kafka.tools.TestEndToEndLatency$ broker_list zookeeper_connect > topic num_messages consumer_fetch_max_wait producer_acks > > > Can anyone helps me what should be put in consumer_fetch_max_wait? Thanks. > > On Tue, Jul 14, 2015 at 5:21 PM, Tao Feng <fengta...@gmail.com> wrote: > > > I think ProducerPerformance microbenchmark only measure between client > to > > brokers(producer to brokers) and provide latency information. > > > > On Tue, Jul 14, 2015 at 11:05 AM, Yuheng Du <yuheng.du.h...@gmail.com> > > wrote: > > > > > Currently, the latency test from kafka test the end to end latency > > between > > > producers and consumers. > > > > > > Is there a way to test the producer to broker and broker to consumer > > > delay seperately? > > > > > > Thanks. > > > > > >
