This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7a87a30 MINOR: Add ability to wait for all instances in an
application to be RUNNING (#7500)
add fa2c61e KAFKA-9058: Lift queriable and materialized restrictions on
FK Join (#7541)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KTable.java | 90 +++++++++-
.../streams/kstream/internals/KTableImpl.java | 123 ++++++++++---
.../streams/integration/ForeignKeyJoinSuite.java | 1 +
.../KTableKTableForeignKeyJoinIntegrationTest.java | 58 +++----
...reignKeyJoinMaterializationIntegrationTest.java | 192 +++++++++++++++++++++
5 files changed, 403 insertions(+), 61 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java
