Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-16282

Allow to get last stable offset (LSO) in kafka-get-offsets.sh

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: In Progress
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None

    Description

      Currently, when using `kafka-get-offsets.sh` to get the offset by time, we have these choices:

      --time <String: <timestamp> /              timestamp of the offsets before that. 
        -1 or latest /                           [Note: No offset is returned, if the
        -2 or earliest /                         timestamp greater than recently
        -3 or max-timestamp /                    committed record timestamp is
        -4 or earliest-local /                   given.] (default: latest)
        -5 or latest-tiered      
      
      

      For the "latest" option, it'll always return the "high watermark" because we always send with the default option: IsolationLevel.READ_UNCOMMITTED. It would be good if the command can support to get the last stable offset (LSO) for transaction support. That is, sending the option with IsolationLevel.READ_COMMITTED

      Attachments

        Activity

          People

            ahmedsobeh Ahmed Sobeh
            showuon Luke Chen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: