This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7027d92 KAFKA-9175: Update MirrorMaker 2 topic/partition metrics
(#7688)
add fecb977 KAFKA-8710; Allow transactional producers to bump producer
epoch [KIP-360] (#7115)
No new revisions were added by this update.
Summary of changes:
.../clients/producer/internals/ProducerBatch.java | 1 +
.../producer/internals/RecordAccumulator.java | 1 +
.../kafka/clients/producer/internals/Sender.java | 1 +
.../producer/internals/TransactionManager.java | 1 +
.../utils}/ProducerIdAndEpoch.java | 13 +-
.../common/message/InitProducerIdRequest.json | 10 +-
.../common/message/InitProducerIdResponse.json | 4 +-
.../clients/producer/internals/SenderTest.java | 1 +
.../producer/internals/TransactionManagerTest.java | 1 +
.../transaction/TransactionCoordinator.scala | 57 +++-
.../coordinator/transaction/TransactionLog.scala | 6 +-
.../transaction/TransactionMetadata.scala | 104 ++++--
.../transaction/TransactionStateManager.scala | 13 +-
.../scala/kafka/log/ProducerStateManager.scala | 17 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 15 +-
.../TransactionCoordinatorConcurrencyTest.scala | 250 ++++++++++++--
.../transaction/TransactionCoordinatorTest.scala | 378 ++++++++++++++++++---
.../TransactionMarkerChannelManagerTest.scala | 10 +-
...sactionMarkerRequestCompletionHandlerTest.scala | 6 +-
.../transaction/TransactionMetadataTest.scala | 130 ++++++-
.../transaction/TransactionStateManagerTest.scala | 22 +-
.../unit/kafka/log/ProducerStateManagerTest.scala | 34 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 37 ++
23 files changed, 933 insertions(+), 179 deletions(-)
rename clients/src/main/java/org/apache/kafka/{clients/producer/internals =>
common/utils}/ProducerIdAndEpoch.java (71%)
