Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8587 One producer per thread for Kafka Streams EOS
  3. KAFKA-9441

Refactor commit logic

    XMLWordPrintableJSON

Details

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

    Description

      Using producer per thread in combination with EOS, it's not possible any longer to commit individual task independently (as done currently).

      We need to refactor StreamsThread, to commit all tasks at the same time for the new model.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue KAFKA-9451 Pass consumer group metadata to producer on commit

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

          Web Link GitHub Pull Request #7977

          Web Link GitHub Pull Request #8105

          Web Link GitHub Pull Request #8215

          Web Link GitHub Pull Request #8218

          Web Link GitHub Pull Request #8356

          Web Link GitHub Pull Request #8776

          Web Link GitHub Pull Request #8833

          Activity

            People

              mjsax Matthias J. Sax
              mjsax Matthias J. Sax
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: