Hi Jan, As discussed, I’ve adopted the position that MessageChooser is orthogonal to topic prioritization and hence outside the scope of KIP-349. -- Nick
> On Jan 14, 2019, at 12:47 AM, Jan Filipiak <jan.filip...@trivago.com> wrote: > > On 14.01.2019 02:48, n...@afshartous.com <mailto:n...@afshartous.com> wrote: > >> >> On reflection, it would be hard to describe the semantics of an API that >> tried to address starvation by temporarily disabling prioritization, and >> then oscillating back and forth. >> Thus I agree that it makes sense not to try and address starvation to >> Mathias’ point that this is intended by design. The KIP has been updated to >> reflect this by removing the second method. >> > > The semantics of almost everything are hard to describe with only those > two tools at hand. Just here to remember yall that Samza already shows > us the interface of a powerful enough abstraction to get stuff done :) > > https://samza.apache.org/learn/documentation/0.12/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html > > <https://samza.apache.org/learn/documentation/0.12/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html> > > welcome :)