mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r424758763
##
File path: docs/streams/developer-guide/processor-api.html
##
@@ -396,33 +396,52 @@ Connecting
Processors and State Stores// and the WordCountProcessor no
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427603579
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -700,12 +703,29 @@ public void process(final ProcessorS
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427605702
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -213,6 +215,48 @@ public void testDrivingSt
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427675683
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -213,6 +215,48 @@ public void testDrivingSt
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427675991
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -700,12 +703,29 @@ public void process(final ProcessorS
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r430786602
##
File path: docs/streams/developer-guide/dsl-api.html
##
@@ -3533,10 +3533,17 @@ KTable-KTable
Foreign-Key
Tip