Let's say I've a single consumer thread reading off multiple partitions (I'll 
have around 10K partitions). As per the documentation on 
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example, there 
are no guarantees on the order in which messages are read off the set of 
partitions. If I wanted to enforce priority-weighted round robin reads off the 
partitions, could I get a pointer on what code to fiddle with? Thanks!

Reply via email to