KAFKA-10186; Abort transaction with pending data with TransactionAbortedException (#9280)
If a transaction is aborted with no underlying exception, throw a new kind of exception - `TransactionAbortedException` to distinguish this from other fatal exceptions. This API change is documented in KIP-654: https://cwiki.apache.org/confluence/display/KAFKA/KIP-654:+Aborted+transaction+with+non-flushed+data+should+throw+a+non-fatal+exception. Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, Jason Gustafson <jason@confluent.io>
显示
- clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java 5 个添加, 2 个删除...a/org/apache/kafka/clients/producer/internals/Sender.java
- clients/src/main/java/org/apache/kafka/common/errors/TransactionAbortedException.java 38 个添加, 0 个删除...ache/kafka/common/errors/TransactionAbortedException.java
- clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java 26 个添加, 0 个删除...g/apache/kafka/clients/producer/internals/SenderTest.java
加载中
想要评论请 注册 或 登录