You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/03/14 04:04:44 UTC

[kafka] branch trunk updated (542853d -> 7945cbc)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 542853d  KAFKA-6145: Pt 2. Include offset sums in subscription (#8246)
     add 7945cbc  MINOR: reuse pseudo-topic in FKJoin (#8296)

No new revisions were added by this update.

Summary of changes:
 .../streams/kstream/internals/KTableImpl.java      |   1 +
 .../SubscriptionResolverJoinProcessorSupplier.java |  11 +-
 .../KTableKTableForeignKeyJoinPseudoTopicTest.java | 138 +++++++++++++++++++++
 ...scriptionResolverJoinProcessorSupplierTest.java |   6 +
 .../kafka/streams/utils/UniqueTopicSerdeScope.java |   6 +
 5 files changed, 155 insertions(+), 7 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinPseudoTopicTest.java