Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-213

MessageChooser should be updated even when backing off consumers

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.6.0, 0.7.0
    • 0.7.0
    • container

    Description

      The SystemConsumers code for updating a MessageChooser is currently wrapped inside the refresher's exponential backoff code. This means that the chooser will not be updated if the refresher is backing off on consumers, even if unprocessedMessages has messages for streams in neededByChooser.

      This bug is described in some detail here

      It seems like the best fix is to move the update code outside of the call() block, and call it independently of refresh.maybeCall.

      Attachments

        1. patch-SAMZA-213.patch
          2 kB
          Anh Thu Vu
        2. SAMZA-213.1.patch
          2 kB
          Chris Riccomini

        Activity

          People

            caseyvu Anh Thu Vu
            criccomini Chris Riccomini
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: