Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-15237

Implement write operation timeout

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 3.7.0
    • None

    Description

      In the scala code, we rely on `offsets.commit.timeout.ms` to bound all the writes. We should do the same in the new code. This is important to ensure that the number of pending response in the purgatory is bound. The name of the config is not ideal but we should keep it for backward compatibility reasons.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #14981

          Activity

            People

              sagarrao Sagar Rao
              dajac David Jacot
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: