Dear Wiki user, You have subscribed to a wiki page or wiki category on "Samza Wiki" for change notification.
The "Pluggable MessageChooser" page has been changed by ChrisRiccomini: https://wiki.apache.org/samza/Pluggable%20MessageChooser?action=diff&rev1=10&rev2=11 Choosing messages when all streams are ahead of their original alignments (3) is an interesting case. Taking our original example, if the 100-message-behind-stream is now 90 messages behind head, then it is 10 messages from its original alignment. If the 1000-messages-behind-stream is now 900 messages behind head, then it is 100 messages from its original alignment. The !MessageChooser would pick the stream that is 10 messages ahead of its original alignment, because it is deemed to be "closest" to its original alignment. - I'm going to declare this strategy as out of scope, but open up a JIRA to track it. + I'm going to declare this strategy as out of scope for [[https://issues.apache.org/jira/browse/SAMZA-2|SAMZA-2]], but [[https://issues.apache.org/jira/browse/SAMZA-67|SAMZA-67]] is open to track it. === DefaultChooser ===
