Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9876 Implement Raft Protocol for Metadata Quorum
  3. KAFKA-10826

Ensure raft io thread wakes up after linger expiration

    XMLWordPrintableJSON

Details

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

    Description

      When scheduling an append, we currently only wakeup the IO thread after the batch is ready to drain. If the IO thread is blocking in `poll()`, there is no guarantee that it will get woken up by a subsequent append. We need to ensure that the thread gets woken up at least once when the linger timer starts ticking so that the IO thread will be ready when the batch is ready to drain.

      Attachments

        Issue Links

          Activity

            People

              hachikuji Jason Gustafson
              hachikuji Jason Gustafson
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: