Re: Poor performance consuming multiple topics

2015-02-11 Thread CJ Woolard
for all of your input, it's been very helpful for us. - CJ On Feb 10, 2015, at 12:10 PM, Guozhang Wang wangg...@gmail.com wrote: CJ, On the consumer side there is another two configs named fetch.min.bytes and fetch.wait.max.ms: http://kafka.apache.org/documentation.html#consumerconfigs

Re: Poor performance consuming multiple topics

2015-02-09 Thread CJ Woolard
.qa.ciq-internal.net # The port to publish to ZooKeeper for clients to use. If this is not set, # it will publish the same port that the broker binds to. advertised.port=9092 Thank you again for your help. CJ

Fetch size

2015-02-08 Thread CJ Woolard
range). Is it possible to set the fetch size to a lower number than the max message size and gracefully handle larger messages (as a trapped exception for example) in order to improve our throughput? Thank you in advance for your help CJ Woolard

Poor performance consuming multiple topics

2015-02-08 Thread Cj
range). Is it possible to set the fetch size to a lower number than the max message size and gracefully handle larger messages (as a trapped exception for example) in order to improve our throughput? Thank you in advance for your help CJ Woolard