Just for the sake of it, are your clocks synchronized using NTP?
On Fri, May 17, 2013 at 8:28 AM, Kishore V. Kopalle <kish...@greenmedsoft.com> wrote: > Hi Francis/Stone, > > I have modified log.default.flush.interval.ms to have a value of 1 in > config/server.properties file. The time did not come down as can be seen > from the following output: > > Message received at 2013-05-17 11:54:02.973: Message produced at 2013-05-17 > 11:54:01.444: Message_1 > Message received at 2013-05-17 11:54:02.974: Message produced at 2013-05-17 > 11:54:01.536: Message_2 > Message received at 2013-05-17 11:54:02.974: Message produced at 2013-05-17 > 11:54:01.537: Message_3 > and so on... > > Regards, > Kishore > > On Fri, May 17, 2013 at 11:49 AM, Francis Dallaire < > francis.dalla...@ubisoft.com> wrote: > >> +1 ... very good suggestion. >> >> >> Sent from Samsung Mobile >> >> >> >> -------- Original message -------- >> From: Stone <stones....@gmail.com> >> Date: 05-17-2013 2:16 AM (GMT-05:00) >> To: users@kafka.apache.org >> Subject: Re: Kafka performance >> >> >> Hi Kishore, >> >> Since a message is only exposed to the consumers after it is flushed. Maybe >> you can try lower log.default.flush.interval.ms which controls the maximum >> time that a message in any topic is kept in memory before flushed to disk ( >> by default it's 3000ms ) >> >> ref - http://kafka.apache.org/07/configuration.html >> >> Best Regards, >> Stone >> >> >> On Fri, May 17, 2013 at 12:46 PM, Kishore Kopalle <kkopa...@gmail.com >> >wrote: >> >> > Hello All, >> > >> > I am evaluating Kafka for use in a real time financial product. I am >> tying >> > to calculate the time it takes for a message to be fetched by the >> consumer >> > after it has been sent by a producer. I am finding that this takes a long >> > time of between 900-1200 ms per message on Windows 7 single core >> processor. >> > Is this the expected result? This seems to be very slow. All my configs >> are >> > default except for the following properties being put: >> > props.put("zk.sessiontimeout.ms", "400"); >> > props.put("zk.synctime.ms", "200"); >> > props.put("autocommit.interval.ms", "1000"); >> > >> > Am I missing any configuration steps for server/producer/consumer? >> > >> > Thanks in advance for answering, >> > Kishore >> > >>
