[
https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056399#comment-17056399
]
ASF GitHub Bot commented on KAFKA-9657:
---------------------------------------
abbccdda commented on pull request #8265: KAFKA-9657: Throw upon offset fetch
unsupported stable flag protocol
URL: https://github.com/apache/kafka/pull/8265
This PR tries to add an internal flag to throw if we hit an unexpected
protocol version for offset fetch. It could be used together with `EOS_BETA`
flag so that if server side downgrades unexpectedly, we shall fail the
application ASAP.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
> Priority: Major
>
> 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)
