Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

where priority is a positive integer.  

This subscribe method takes a list of TopicPriority as a parameter.  

Code Block
public void subscribe(java.util.List<TopicPriority> topicPriorities);

This subscribe method parameter has an additional parameter maxDelta that's used to prevent starvation  Starvation of lower priority topics is not addressed in this KIP and a possible consequence of invoking the API

Code Block
public void subscribe(java.util.List<TopicPriority> topicPriorities, Integer maxDelta);

If the delta (in minutes) between the oldest message in the highest and lowest priority topics exceeds

...

Proposed Changes

The new behavior is only in effect when the user specifies priorities for topics using the above new API.  In this case topics are checked starting from highest priority first and then in descending order based on priority.  All events must be consumed from a higher priority topic before consumption is performed on a lower priority topic. 

...