mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r474353890
##########
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##########
@@ -123,7 +123,7 @@ public void shouldAllowJoinMaterializedFilteredKTable() {
assertThat(
topology.stateStores().size(),
- equalTo(1));
+ equalTo(2));
Review comment:
This is surprising to me -- need to dig into the code I guess, but I
though enabling to send old values would _not_ trigger any upstream
materialization but only take effect _if_ the store is materializes already
(but would be ignored otherwise). Seems my assumption is wrong though.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
