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

Add configurable throw on unsupported protocol

    XMLWordPrintableJSON

Details

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

    Description

      Right now Stream could not handle the case when the brokers are downgraded, thus potentially could violate EOS requirement. We could add an (internal) config to either consumer or producer to actually crash on unsupported version when the broker connecting to is on an older version unexpectedly, to prevent this case from causing correctness concern.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #8265

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: