This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from b62f2a1 KAFKA-8496: System test for KIP-429 upgrades and
compatibility (#7529)
add f93c473 KAFKA-9000: fix flaky FK join test by using TTD (#7517)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 4 +-
.../streams/integration/ForeignKeyJoinSuite.java | 4 +-
.../KTableKTableForeignKeyJoinIntegrationTest.java | 1024 ++++++++------------
...scriptionResolverJoinProcessorSupplierTest.java | 223 +++++
.../streams/processor/MockProcessorContext.java | 9 +
5 files changed, 637 insertions(+), 627 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplierTest.java
