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!
Single thread, Multiple partitions
Sudarshan Kadambi (BLOOMBERG/ 731 LEXIN) Tue, 08 Apr 2014 10:58:38 -0700
- Single thread, Multiple partition... Sudarshan Kadambi (BLOOMBERG/ 731 LEXIN)
- RE: Single thread, Multiple ... Seshadri, Balaji
- RE: Single thread, Multiple ... Sudarshan Kadambi (BLOOMBERG/ 731 LEXIN)
- RE: Single thread, Multi... Seshadri, Balaji
- RE: Single thread, Multiple ... Sudarshan Kadambi (BLOOMBERG/ 731 LEXIN)
- RE: Single thread, Multi... Seshadri, Balaji
- Re: Single thread, Multi... Kiran Nagasubramanian