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

Make CoordinatorStreamSystemConsumer skip error messages

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: container
    • Labels:
      None

      Description

      Not sure if it's a good idea. Looking for some feedbacks.

      There are two reasons in my mind:

      1. when users accidentally publish error-messages to the coordinatorStreamConsumer, there is no easy way to remove that messages, this breaks the whole system because we wont be able to run the bootstrap() successfully.

      2. if the coordinator messages are not serialized correctly, this breaks the bootstrap() as well.

        Attachments

          Activity

            People

            • Assignee:
              gustavoanatoly Gustavo Anatoly
              Reporter:
              closeuris Yan Fang
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: