KAFKA-13769: Add tests for ForeignJoinSubscriptionProcessorSupplier (#12437)
Reviewers: Adam Bellemare <adam.bellemare@gmail.com>, John Roesler <vvcephei@apache.org>
显示
- 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/SubscriptionWrapper.java 4 个添加, 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/SubscriptionWrapperSerdeTest.java 11 个添加, 11 个删除...nternals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java
加载中
想要评论请 注册 或 登录