KAFKA-13769 Fix version check in SubscriptionStoreReceiveProcessorSup… (#784)
* KAFKA-13769: Add tests for ForeignJoinSubscriptionProcessorSupplier (#12437) Reviewers: Adam Bellemare <adam.bellemare@gmail.com>, John Roesler <vvcephei@apache.org> * KAFKA-13769 Fix version check in SubscriptionStoreReceiveProcessorSupplier
显示
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java 16 个添加, 2 个删除...streams/kstream/internals/foreignkeyjoin/CombinedKey.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java 24 个添加, 0 个删除...internals/foreignkeyjoin/SubscriptionResponseWrapper.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java 1 个添加, 1 个删除...ignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java 25 个添加, 1 个删除...kstream/internals/foreignkeyjoin/SubscriptionWrapper.java
- streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplierTest.java 377 个添加, 0 个删除...keyjoin/ForeignJoinSubscriptionProcessorSupplierTest.java
- streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplierTest.java 517 个添加, 0 个删除...eyjoin/SubscriptionStoreReceiveProcessorSupplierTest.java
- streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java 11 个添加, 11 个删除...nternals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java
加载中
想要评论请 注册 或 登录