I've been looking at the new consumer api outlined here:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design

One issue in the current high-level consumer, is that it does not do a good
job of distributing a set of topics between multiple consumers, unless each
topic has multiple partitions.  This has always seemed strange to me, since
at the end of the day, even for single partition topics, the basic unit of
consumption is still at the partition level (so you'd expect rebalancing to
try to evenly distribute partitions (regardless of the topic)).

It's not clearly spelled out in the new consumer api wiki, so I'll just
ask, will this issue be addressed in the new api?  I think I've asked this
before, but I wanted to go check again, and am not seeing this explicitly
addressed in the design.

Thanks

Jason

Reply via email to