Thanks for all your replies. Jun, perhaps you are right. There seems to be no other choice but to use more brokers, at least for the current version.
Jay, you've got what I mean. And thanks for sharing your approach, though we are under different circumstances. Magnus, as you said, my consumer performance is the problem. However, it's due to the network bottleneck for I've set more than one consumer group. Thanks again for your attentions. On Fri, Dec 13, 2013 at 1:19 AM, Magnus Edenhill <mag...@edenhill.se> wrote: > Sounds to me your consumer performance is the problem, not the producer. > So either make your consumers faster or make them consume but drop messages > to keep up with the producer speed. > This also gives you some means of keeping track of how many messages are > lost, why, and when. > > And just for reference; the Kafka broker->consumer throughput is far higher > than the producer->broker throughput. > > > 2013/12/12 xingcan <xingc...@gmail.com> > > > Guozhang, > > > > Thanks for your prompt replay. I got two 300GB SAS disks for each borker. > > At peak time, the produce speed for each broker is about 70MB/s. > > Apparently, > > this speed is already restricted by network. While, the consume speed is > > lower > > for some topics are consumed by more than one group. Under this > > circumstance, > > if the peak time lasts for hours, my disks will be fully used. > > > > > > On Thu, Dec 12, 2013 at 2:00 PM, Guozhang Wang <wangg...@gmail.com> > wrote: > > > > > One possible approach is to change the retention policy on broker. > > > > > > How large your messages can accumulate on brokers at peak time? > > > > > > Guozhang > > > > > > > > > On Wed, Dec 11, 2013 at 9:09 PM, xingcan <xingc...@gmail.com> wrote: > > > > > > > Hi, > > > > > > > > In my application, the produce speed could be very high at some > > specific > > > > time in a day while return > > > > to a low speed at the rest of time. Frequently, my data logs are > > flushed > > > > away before they are being > > > > consumed by clients due to lacking disk space during the busy times. > > > > > > > > Increasing consume speed seems to be difficult and adding space for > log > > > > files are also not a ultimate solution. Any suggestions for this > > problem? > > > > Are there any speed control mechanism in Kafka? > > > > > > > > Thanks. > > > > > > > > -- > > > > *Xingcan* > > > > > > > > > > > > > > > > -- > > > -- Guozhang > > > > > > > > > > > -- > > *Xingcan* > > > -- *Xingcan*
