...
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.
...