You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2023/04/13 00:04:59 UTC
[kafka] branch trunk updated (88e2d6b8c23 -> 56dcb837a2f)

This is an automated email from the ASF dual-hosted git repository.

junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from 88e2d6b8c23 KAFKA-14834: [3/N] Timestamped lookups for stream-table joins (#13509)
     add 56dcb837a2f KAFKA-14561: Improve transactions experience for older clients by ensuring ongoing transaction (#13391)

No new revisions were added by this update.

Summary of changes:
 .../common/message/AddPartitionsToTxnRequest.json  |   5 +-
 core/src/main/java/kafka/server/NetworkUtils.java  |  90 ++++++++
 .../server/builders/ReplicaManagerBuilder.java     |  12 +-
 core/src/main/scala/kafka/cluster/Partition.scala  |   4 +
 core/src/main/scala/kafka/log/UnifiedLog.scala     |   5 +
 .../main/scala/kafka/network/RequestChannel.scala  |  40 +++-
 .../kafka/server/AddPartitionsToTxnManager.scala   | 180 +++++++++++++++
 .../src/main/scala/kafka/server/BrokerServer.scala |   8 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  15 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |  10 +
 .../scala/kafka/server/KafkaRequestHandler.scala   |  74 +++++++
 core/src/main/scala/kafka/server/KafkaServer.scala |   7 +-
 .../main/scala/kafka/server/ReplicaManager.scala   | 206 ++++++++++++-----
 .../kafka/server/KafkaRequestHandlerTest.scala     |  80 +++++++
 .../scala/unit/kafka/cluster/PartitionTest.scala   |  60 ++++-
 .../AbstractCoordinatorConcurrencyTest.scala       |   4 +-
 .../coordinator/group/GroupCoordinatorTest.scala   |   8 +
 .../group/GroupMetadataManagerTest.scala           |  20 ++
 .../transaction/TransactionStateManagerTest.scala  |  12 +
 .../unit/kafka/network/SocketServerTest.scala      |   2 +
 .../server/AddPartitionsToTxnManagerTest.scala     | 245 +++++++++++++++++++++
 .../AddPartitionsToTxnRequestServerTest.scala      |   1 -
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  66 +++++-
 .../unit/kafka/server/ReplicaManagerTest.scala     | 197 ++++++++++++++++-
 24 files changed, 1275 insertions(+), 76 deletions(-)
 create mode 100644 core/src/main/java/kafka/server/NetworkUtils.java
 create mode 100644 core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala
 create mode 100644 core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/AddPartitionsToTxnManagerTest.scala