Just clarifying that the API below would be in addition to the API specified in KIP-349
https://cwiki.apache.org/confluence/display/KAFKA/KIP-349%3A+Priorities+for+Source+Topics -- Nick > On Aug 30, 2018, at 9:57 AM, n...@afshartous.com wrote: > > Here’s an attempt at incorporating a Samza MessageChooser type interface. > -- > Nick > > > New interface TopicPrioritizer allows one to create a method implementation > that prioritizes topics. The topic priorities that were assigned with method > KafkaConsumer.subscribe may or may not be used. The input is the list of > subscribed topics, and output is ordered list of topics. The ordering > represents the priority that the TopicPrioritizer implementation has > assigned. Calls to KafkaConsumer.poll will use the TopicPrioritizer to > determine the priority of topics. > > interface TopicPrioritizer { > List<TopicPriority> prioritize(List<TopicPriority> topicPriorities); > } > > > New method KafkaConsumer.registerTopicPrioritizer is used to register the > TopicPrioritizer > > public void registerTopicPrioritizer(TopicPrioritizer topicPrioritizer);
