lucasbru opened a new pull request, #13811:
URL: https://github.com/apache/kafka/pull/13811
This PR fixes three issues:
* `InvalidProducerEpochException` was not handled consistently.
`InvalidProducerEpochException` used to be able to be return via both
transactional response and produce response, but as of KIP-588 (2.7+),
transactional responses should not return `InvalidProducerEpochException`
anymore, only produce responses can. It can happen that older brokers may still
return `InvalidProducerEpochException` for transactional responses; these must
be converted to the newer `ProducerFencedException`. This conversion wasn't
done for `TxnOffsetCommit` (sent to the group coordinator).
`InvalidTxnStateException` was double-wrapped in `KafkaException`, whereas
other exceptions are usually wrapped only once. Furthermore,
`InvalidTxnStateException` was not handled at all for in `AddOffsetsToTxn`
response, where it should be a possible error as well, according to API
documentation.
- According to API documentation, `UNSUPPORTED_FOR_MESSAGE_FORMAT` is not
possible for `TxnOffsetCommit`, but it looks like it is, and it is being
handled there, so I updated the API documentation.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
