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

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

      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

            People

            • Assignee:
              Unassigned
              Reporter:
              closeuris Yan Fang

              Dates

              • Created:
                Updated:

                Issue deployment