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

Posted to commits@kafka.apache.org by ab...@apache.org on 2020/11/13 22:36:32 UTC

[kafka] branch trunk updated (cfc8135 -> cb3dc67)

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

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


    from cfc8135  MINOR: demote "Committing task offsets" log to DEBUG (#9489)
     add cb3dc67  KAFKA-6687: rewrite topology to allow reading the same topic multiple times in the DSL (#9582)

No new revisions were added by this update.

Summary of changes:
 .../kstream/internals/InternalStreamsBuilder.java  | 47 ++++++++++++
 .../kstream/internals/graph/StreamSourceNode.java  | 28 ++++++-
 .../internals/InternalTopologyBuilder.java         | 14 +---
 .../streams/processor/internals/StreamTask.java    |  2 +-
 .../apache/kafka/streams/StreamsBuilderTest.java   | 89 ++++++++++++++++++++++
 .../internals/InternalStreamsBuilderTest.java      |  5 --
 .../processor/internals/StreamTaskTest.java        |  2 +-
 .../processor/internals/StreamThreadTest.java      |  8 +-
 8 files changed, 167 insertions(+), 28 deletions(-)