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

Integration test for new EOS model with vanilla Producer and Consumer

Attach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

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

    Description

      We would like to extend the `TransactionMessageCopier` to use the new subscription mode consumer and do a system test based off that in order to verify the new semantic actually works.

      We also want to make sure the backward compatibility is maintained by using group metadata API in existing tests as well.

       

      A minor public change is also included within this PR by setting `transaction.abort.timed.out.transaction.cleanup.interval.ms` default to 10000 ms (10 seconds) on broker side 

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            bchen225242 Boyang Chen
            bchen225242 Boyang Chen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Issue deployment