Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15865

Ensure consumer.poll() execute autocommit callback

    XMLWordPrintableJSON

Details

    Description

      When the network thread completes autocommits, we need to send a message/event to the application to notify the thread to execute the callback.  In KAFKA-15327, the network thread sends a AutoCommitCompletionBackgroundEvent to the polling thread.  The polling thread should trigger the OffsetCommitCallback upon receiving it.

      Attachments

        Issue Links

          is blocked by

          Sub-task - The sub-task of the issue KAFKA-15327 Client consumer should commit offsets on close

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #14831

          Activity

            People

              lucasbru Lucas Brutschy
              pnee Philip Nee
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: