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 c9209892053 MINOR Set min and max heap for Checkstyle (#18071)
add 755adf8a566 KAFKA-14563: RemoveClient-Side AddPartitionsToTxn Requests
(#17698)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/producer/KafkaProducer.java | 10 +-
.../kafka/clients/producer/internals/Sender.java | 11 +-
.../producer/internals/TransactionManager.java | 55 ++--
.../kafka/common/requests/ProduceRequest.java | 13 +-
.../common/requests/TxnOffsetCommitRequest.java | 33 +-
.../resources/common/message/ProduceRequest.json | 7 +-
.../resources/common/message/ProduceResponse.json | 4 +-
.../common/message/TxnOffsetCommitRequest.json | 7 +-
.../common/message/TxnOffsetCommitResponse.json | 4 +-
.../kafka/clients/producer/KafkaProducerTest.java | 134 +++++++-
.../producer/internals/RecordAccumulatorTest.java | 2 +-
.../clients/producer/internals/SenderTest.java | 2 +-
.../producer/internals/TransactionManagerTest.java | 251 +++++++++++----
.../kafka/common/requests/ProduceRequestTest.java | 220 ++++++-------
.../kafka/common/requests/RequestResponseTest.java | 25 +-
.../requests/TxnOffsetCommitRequestTest.java | 7 +-
.../kafka/coordinator/common/runtime/TestUtil.java | 21 ++
.../group/CoordinatorPartitionWriter.scala | 4 +-
.../kafka/coordinator/group/GroupCoordinator.scala | 2 +-
.../transaction/TransactionCoordinator.scala | 357 +++++++++++++++++----
.../transaction/TransactionMetadata.scala | 28 +-
core/src/main/scala/kafka/log/UnifiedLog.scala | 9 +-
.../kafka/server/AddPartitionsToTxnManager.scala | 35 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
.../main/scala/kafka/server/ReplicaManager.scala | 2 +-
.../java/kafka/admin/AdminFenceProducersTest.java | 11 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 4 +-
.../integration/kafka/api/TransactionsTest.scala | 62 ++--
.../transaction/TransactionCoordinatorTest.scala | 242 ++++++++++----
.../transaction/TransactionMetadataTest.scala | 127 +++++++-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 18 +-
.../server/AddPartitionsToTxnManagerTest.scala | 77 ++---
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +
.../unit/kafka/server/ProduceRequestTest.scala | 25 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 38 +--
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +-
.../group/GroupCoordinatorServiceTest.java | 7 +-
.../jmh/producer/ProducerRequestBenchmark.java | 2 +-
38 files changed, 1401 insertions(+), 462 deletions(-)
