Thank you, Tao! On Jul 15, 2015 6:27 PM, "Tao Feng" <fengta...@gmail.com> wrote:
> Sorry Yufeng, You should change it in $KAFKA_HEAP_OPTS. > > On Wed, Jul 15, 2015 at 3:09 PM, Tao Feng <fengta...@gmail.com> wrote: > > > Hi Yuheng, > > > > You could add the -Xmx1024m in > > https://github.com/apache/kafka/blob/trunk/bin/kafka-run-class.sh > > KAFKA_JVM_PERFORMANCE_OPTS. > > > > > > > > On Wed, Jul 15, 2015 at 12:51 AM, Yuheng Du <yuheng.du.h...@gmail.com> > > wrote: > > > >> Tao, > >> > >> If I am running on the command line the following command > >> >bin/kafka-run-class.sh kafka.tools.TestEndToEndLatency > 192.168.1.3:9092 > >> 192.168.1.1:2181 speedx3 50000000 100 1 -Xmx1024m > >> > >> It promped that it is not correct. So where should I put the -Xmx1024m > >> option? Thanks. > >> > >> > >> > >> On Wed, Jul 15, 2015 at 3:44 AM, Tao Feng <fengta...@gmail.com> wrote: > >> > >> > (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. > >> > > > > > >> > > > > >> > > > >> > > >> > > > > >
