This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
from c752c0a0931 KAFKA-14623: OAuth's HttpAccessTokenRetriever potentially
leaks secrets in logging (#13119)
new 0e052af3c77 KAFKA-13769: Add tests for
ForeignJoinSubscriptionProcessorSupplier (#12437)
new 0ef910a235c KAFKA-13769 Fix version check in
SubscriptionStoreReceiveProcessorSupplier (#12535)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../internals/foreignkeyjoin/CombinedKey.java | 18 +-
.../SubscriptionResponseWrapper.java | 24 +
.../SubscriptionStoreReceiveProcessorSupplier.java | 2 +-
.../foreignkeyjoin/SubscriptionWrapper.java | 26 +-
...reignJoinSubscriptionProcessorSupplierTest.java | 377 +++++++++++++++
...scriptionStoreReceiveProcessorSupplierTest.java | 517 +++++++++++++++++++++
.../SubscriptionWrapperSerdeTest.java | 22 +-
7 files changed, 971 insertions(+), 15 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplierTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplierTest.java
