Boyang Chen created KAFKA-9657:
----------------------------------

             Summary: Add configurable throw on unsupported protocol
                 Key: KAFKA-9657
                 URL: https://issues.apache.org/jira/browse/KAFKA-9657
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Boyang Chen


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to