kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (7027d92 -> fecb977)
Date Thu, 14 Nov 2019 01:41:28 GMT
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%)


Mime
View raw message