Skip to content

Commit

Permalink
Update upstream to https://github.com/apache/kafka.git/commit/184b891…
Browse files Browse the repository at this point in the history 
…8717efc322cf01557ef90540ff5a6c2b0
  • Loading branch information
@depot-bot
depot-bot committed Jan 30, 2025
1 parent 9ecd9f6 commit 72f9974
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion upstream
Submodule upstream updated 25 files
+33 −0 core/src/main/scala/kafka/raft/DefaultExternalKRaftMetrics.scala
+4 −2 core/src/main/scala/kafka/raft/RaftManager.scala
+4 −1 core/src/main/scala/kafka/server/SharedServer.scala
+3 −2 core/src/main/scala/kafka/tools/TestRaftServer.scala
+57 −0 core/src/test/scala/kafka/raft/DefaultExternalKRaftMetricsTest.scala
+1 −0 core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
+21 −2 metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java
+19 −0 metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsTest.java
+26 −0 raft/src/main/java/org/apache/kafka/raft/ExternalKRaftMetrics.java
+10 −4 raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
+19 −1 raft/src/main/java/org/apache/kafka/raft/LeaderState.java
+9 −2 raft/src/main/java/org/apache/kafka/raft/QuorumState.java
+14 −0 raft/src/main/java/org/apache/kafka/raft/VoterSet.java
+21 −1 raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java
+95 −46 raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftMetrics.java
+129 −1 raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java
+3 −0 raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java
+6 −2 raft/src/test/java/org/apache/kafka/raft/LeaderStateTest.java
+4 −1 raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
+10 −1 raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
+4 −1 raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
+81 −10 raft/src/test/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachineTest.java
+65 −8 raft/src/test/java/org/apache/kafka/raft/internals/KafkaRaftMetricsTest.java
+24 −1 server/src/main/java/org/apache/kafka/server/metrics/BrokerServerMetrics.java
+19 −1 server/src/test/java/org/apache/kafka/server/metrics/BrokerServerMetricsTest.java

0 comments on commit 72f9974

Please sign in to comment.