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

Add generic lag metric from high watermark - last processed message

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 0.9.0
    • None
    • metrics

    Description

      This is a follow-up ticket for SAMZA-503 .

      The gauge is to show the lag between the offset of the most recent message on the incoming stream and the offset of the most recent message that the StreamTask has processed.

      As discussed in SAMZA-503, we could add a IncomingMessageEnvelope.getMaxOffset() API .

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            closeuris Yan Fang

            Dates

              Created:
              Updated:

              Slack

                Issue deployment