You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by js...@apache.org on 2024/08/14 19:42:12 UTC

(kafka) branch trunk updated (5dd4d84eecb -> 0f7cd4dcdeb)

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

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


    from 5dd4d84eecb KAFKA-17272: [1/2] System test framework for consumer protocol migration (#16845)
     add 0f7cd4dcdeb KAFKA-17304; Make RaftClient API for writing to log explicit (#16862)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/tools/TestRaftServer.scala    |   3 +-
 .../kafka/controller/OffsetControlManager.java     |  10 +-
 .../apache/kafka/controller/QuorumController.java  |  23 +-
 .../errors/EventHandlerExceptionInfo.java          |   7 -
 .../kafka/metadata/util/BatchFileWriter.java       |   6 +-
 .../kafka/controller/OffsetControlManagerTest.java |   2 +-
 .../QuorumControllerMetricsIntegrationTest.java    |   2 +-
 .../kafka/controller/QuorumControllerTest.java     | 112 ------
 .../errors/EventHandlerExceptionInfoTest.java      |  23 --
 .../kafka/image/publisher/SnapshotEmitterTest.java |  10 +-
 .../org/apache/kafka/metalog/LocalLogManager.java  |  77 +---
 .../apache/kafka/metalog/LocalLogManagerTest.java  |   3 +-
 .../kafka/metalog/LocalLogManagerTestEnv.java      |  19 +-
 .../org/apache/kafka/raft/KafkaRaftClient.java     |  45 ++-
 .../java/org/apache/kafka/raft/LeaderState.java    |   1 -
 .../java/org/apache/kafka/raft/RaftClient.java     |  68 ++--
 .../raft/errors/UnexpectedBaseOffsetException.java |  29 --
 .../kafka/raft/internals/BatchAccumulator.java     | 148 ++++---
 .../kafka/snapshot/RecordsSnapshotWriter.java      |   4 +-
 .../kafka/raft/KafkaRaftClientSnapshotTest.java    |  12 +-
 .../org/apache/kafka/raft/KafkaRaftClientTest.java |  93 ++---
 .../org/apache/kafka/raft/ReplicatedCounter.java   |   3 +-
 .../kafka/raft/internals/BatchAccumulatorTest.java | 424 ++++++++++-----------
 23 files changed, 455 insertions(+), 669 deletions(-)
 delete mode 100644 raft/src/main/java/org/apache/kafka/raft/errors/UnexpectedBaseOffsetException.java