This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 159d25a7df2 KAFKA-16276: Update transactions_test.py to support
KIP-848’s group protocol config (#15567)
add 2e8d69b78ca KAFKA-16314: Introducing the AbortableTransactionException
(#15486)
No new revisions were added by this update.
Summary of changes:
.../producer/internals/TransactionManager.java | 30 +++--
...ion.java => AbortableTransactionException.java} | 4 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../common/message/AddOffsetsToTxnRequest.json | 4 +-
.../common/message/AddOffsetsToTxnResponse.json | 4 +-
.../common/message/AddPartitionsToTxnRequest.json | 4 +-
.../common/message/AddPartitionsToTxnResponse.json | 4 +-
.../resources/common/message/EndTxnRequest.json | 4 +-
.../resources/common/message/EndTxnResponse.json | 4 +-
.../common/message/FindCoordinatorRequest.json | 4 +-
.../common/message/FindCoordinatorResponse.json | 4 +-
.../common/message/InitProducerIdRequest.json | 4 +-
.../common/message/InitProducerIdResponse.json | 4 +-
.../resources/common/message/ProduceRequest.json | 4 +-
.../resources/common/message/ProduceResponse.json | 4 +-
.../common/message/TxnOffsetCommitRequest.json | 4 +-
.../common/message/TxnOffsetCommitResponse.json | 4 +-
.../clients/producer/internals/SenderTest.java | 40 +++++++
.../producer/internals/TransactionManagerTest.java | 121 +++++++++++++++++++++
.../group/CoordinatorPartitionWriter.scala | 9 +-
.../kafka/coordinator/group/GroupCoordinator.scala | 8 +-
.../group/GroupCoordinatorAdapter.scala | 3 +-
.../transaction/TransactionCoordinator.scala | 2 +-
.../kafka/server/AddPartitionsToTxnManager.scala | 28 ++++-
core/src/main/scala/kafka/server/KafkaApis.scala | 5 +-
.../main/scala/kafka/server/ReplicaManager.scala | 33 ++++--
.../AbstractCoordinatorConcurrencyTest.scala | 3 +-
.../group/CoordinatorPartitionWriterTest.scala | 8 +-
.../group/GroupCoordinatorAdapterTest.scala | 3 +-
.../group/GroupCoordinatorConcurrencyTest.scala | 6 +-
.../coordinator/group/GroupCoordinatorTest.scala | 7 +-
.../transaction/TransactionCoordinatorTest.scala | 4 +-
.../server/AddPartitionsToTxnManagerTest.scala | 66 ++++++++---
.../AddPartitionsToTxnRequestServerTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 5 +
.../unit/kafka/server/ReplicaManagerTest.scala | 44 +++++---
.../coordinator/group/GroupCoordinatorService.java | 3 +-
.../group/runtime/CoordinatorRuntime.java | 7 +-
.../coordinator/group/runtime/PartitionWriter.java | 4 +-
.../group/GroupCoordinatorServiceTest.java | 2 +
.../group/runtime/CoordinatorRuntimeTest.java | 26 +++--
.../group/runtime/InMemoryPartitionWriter.java | 3 +-
42 files changed, 424 insertions(+), 112 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/{IneligibleReplicaException.java
=> AbortableTransactionException.java} (87%)
