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/04/29 21:18:20 UTC

[kafka] branch trunk updated (7907b5a -> 688f2e9)

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 7907b5a  KAFKA-9832: fix attempt to commit non-running tasks (#8580)
     add 688f2e9  KAFKA-9925: decorate pseudo-topics with app id (#8574)

No new revisions were added by this update.

Summary of changes:
 .../streams/kstream/internals/KTableImpl.java      | 24 +++++++++++++----
 .../foreignkeyjoin/CombinedKeySchema.java          | 17 +++++++-----
 ...reignJoinSubscriptionSendProcessorSupplier.java | 17 +++++++-----
 .../SubscriptionResolverJoinProcessorSupplier.java | 10 +++++---
 .../foreignkeyjoin/SubscriptionWrapperSerde.java   | 30 +++++++++++++++-------
 .../internals/InternalTopologyBuilder.java         |  4 +++
 .../KTableKTableForeignKeyJoinScenarioTest.java    | 30 +++++++++++-----------
 .../foreignkeyjoin/CombinedKeySchemaTest.java      | 30 ++++++++++++++--------
 ...scriptionResolverJoinProcessorSupplierTest.java | 12 ++++-----
 .../SubscriptionWrapperSerdeTest.java              |  8 +++---
 10 files changed, 118 insertions(+), 64 deletions(-)