[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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

[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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

[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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

[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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

[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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

[GitHub] [kafka] mjsax commented on a change in pull request #6824: KAFKA-7523: Add ConnectedStoreProvider to Processor API

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