Hey Nick, This seems like a non-trivial change and more importantly - a change in the public interface. As such, following our contributing guidelines <https://kafka.apache.org/contributing>, it warrants a KIP <https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals> (Kafka Improvement Proposal). Please look into those, write an extensive one and start a [DISCUSS] thread in the mailing group. You might not have permissions to create one and you'll need to ask in a separate e-mail for somebody to give you (I can't).
This seems like an interesting change, I'm looking forward to it! Best, Stanislav On Wed, Jul 18, 2018 at 5:07 AM Nick <n...@afshartous.com> wrote: > Hi all, > > I picked up KAFKA-6690 Priorities for Source Topics. > > https://issues.apache.org/jira/browse/KAFKA-6690 > > In the ticket I made some notes about extending the API to incorporate > topic priorities. > > For implementation, I was thinking of filtering out lower priority > topics in method Fetcher.fetchablePartitions. > > Thanks for any input. > > Regards, > -- > Nick > -- Best, Stanislav
