Skip to content

Commit

Permalink
Update upstream to https://github.com/apache/kafka.git/commit/ad031b9…
Browse files Browse the repository at this point in the history 
…9d312cdfe452965c841e22c1ab391956e
  • Loading branch information
@depot-bot
depot-bot committed Feb 4, 2025
1 parent bdd7834 commit 0c45d86
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion upstream
Submodule upstream updated 21 files
+446 −0 core/src/test/java/kafka/server/integration/EligibleLeaderReplicasIntegrationTest.java
+18 −13 metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
+5 −4 metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
+8 −7 metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+90 −28 metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java
+1 −1 metadata/src/test/java/org/apache/kafka/controller/ProducerIdControlManagerTest.java
+10 −9 metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
+35 −7 metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
+6 −7 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java
+17 −17 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java
+7 −7 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignKeyExtractor.java
+13 −13 .../main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignTableJoinProcessorSupplier.java
+21 −20 .../src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ResponseJoinProcessorSupplier.java
+31 −28 .../main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinProcessorSupplier.java
+13 −16 ...in/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionReceiveProcessorSupplier.java
+5 −5 ...ms/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java
+8 −8 ...c/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java
+27 −26 .../main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplier.java
+5 −6 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java
+24 −24 streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java
+6 −4 ...t/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java

0 comments on commit 0c45d86

Please sign in to comment.