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

Add generic lag metric from high watermark - last processed message

    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
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated: