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 2696a6d7a19 KAFKA-17767 Load test catalog data [3/n] (#17654)
add e14a81b4b28 KAFKA-14562 [2/3]: Implement epoch bump after every
transaction (KIP-890) (#17402)
No new revisions were added by this update.
Summary of changes:
.../producer/internals/TransactionManager.java | 17 +-
.../kafka/common/requests/EndTxnRequest.java | 13 +-
.../resources/common/message/EndTxnRequest.json | 2 +-
.../producer/internals/TransactionManagerTest.java | 174 ++++++++++++++++++---
.../kafka/common/requests/EndTxnRequestTest.java | 40 ++++-
.../kafka/common/requests/RequestResponseTest.java | 5 +-
.../transaction/TransactionMetadata.scala | 56 +++++--
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
.../kafka/api/TransactionsExpirationTest.scala | 18 ++-
.../integration/kafka/api/TransactionsTest.scala | 128 +++++++++++++--
.../kafka/server/QuorumTestHarness.scala | 13 +-
.../src/test/scala/kafka/utils/TestInfoUtils.scala | 8 +
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 2 +-
.../TransactionMarkerChannelManagerTest.scala | 50 +++++-
.../transaction/TransactionMetadataTest.scala | 24 +--
.../scala/unit/kafka/server/KafkaApisTest.scala | 8 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +-
17 files changed, 484 insertions(+), 79 deletions(-)
