I got java out of heap error when running end to end latency test: yuhengdu@consumer0:/packages/kafka_2.10-0.8.2.1$ bin/kafka-run-class.sh kafka.tools.TestEndToEndLatency 192.168.1.3:9092 192.168.1.1:2181 speedx3 50000000 100 1
Exception in thread "main" java.lang.OutOfMemoryError: Java heap space at kafka.tools.TestEndToEndLatency$.main(TestEndToEndLatency.scala:69) at kafka.tools.TestEndToEndLatency.main(TestEndToEndLatency.scala) What command should I do to add java heap space to jvm? Thanks! Yuheng On Wed, Jul 15, 2015 at 3: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. >> > >> > >
