Is it worth spelling out explicitly what the behavior is when two topics have the same priority? I'm a bit fuzzy on how we choose what topics to consume from right now, if I'm being honest, so it could be useful to outline the current behavior in the background and to spell out how that would change (or if it would change) when two topics are given the same priority.
Also, how does this play with max.poll.records? Does the consumer read from all the topics in priority order until we've hit the number of records or the poll timeout? Or does it immediately return the high priority records without pulling low priority records? On Wed, Aug 8, 2018 at 8:39 PM <n...@afshartous.com> wrote: > > Hi All, > > Calling for a vote on KIP-349 > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-349%3A+Priorities+for+Source+Topics > < > https://cwiki.apache.org/confluence/display/KAFKA/KIP-349:+Priorities+for+Source+Topics > > > > Cheers, > -- > Nick > > > >
