mjsax commented on PR #14426: URL: https://github.com/apache/kafka/pull/14426#issuecomment-1977704070
Looking into the test, we create `new KafkaStreams(builder.build(streamsConfig), streamsConfig)`, but we don't pass in the mock time object. So KS creates it's own `Time` object, so it's decoupled... But yes, setting `streamsConfig.put(InternalConfig.EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX, 0L);` is a valid fix, and we do the same thing for others test -- in the end, this config is a perf optimization, but for testing we can disable it by setting it to zero. > I do not understand however, why this test worked before? Not 100% sure TBO. -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
