Don't know if you figured this out, but I suspect the problem is that
bin/kafka-server-start.sh in the current 0.8.0 code has this line:
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
Which would override your attempt to set the heap size lower (or higher,
for that matter).
On Fri, Jan 31, 2014 at 1:45
This is an expected exception.
On Sat, Feb 1, 2014 at 9:29 PM, Ranjith Venkatesan
wrote:
> Hi ,
>
> We are evaluating kafka 0.8 for our product as a queue system. Our
> architecture remains simple. Our producer (single) will send mesages to any
> of the topics in broker. Thread will be ru
I think the most common motivate of having a customized partitioner is to
make sure some messages always go to the same partition, but people may
seldom want to know about which partition exactly they go to. If that is
true, why not just assign the same byte array as partition key with the
default
