Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-12336

JmsIO should allow using custom timestamp policy to track watermark

Details

    • Improvement
    • Status: Triage Needed
    • P3
    • Resolution: Unresolved
    • None
    • None
    • io-java-jms
    • None

    Description

      Similar to CustomTimestampPolicyWithLimitedDelay in KafkaIO, JmsIO can consider adding the same functionality to allow configuring timestamp policy.

      Attachments

        Activity

          People

            Unassigned Unassigned
            boyuanz Boyuan Zhang
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: