Skip to content

Commit 37d4225

Browse files
committed
Github comment
1 parent aa10538 commit 37d4225

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/io/confluent/examples/streams/StreamToStreamJoinIntegrationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ public void shouldJoinTwoStreams() {
101101
JoinWindows.of(Duration.ofSeconds(5)),
102102
// In this specific example, we don't need to define join serdes explicitly because the key, left value, and
103103
// right value are all of type String, which matches our default serdes configured for the application. However,
104-
// we want to showcase the use of `Joined.with(...)` in case your code needs a different type setup.
104+
// we want to showcase the use of `StreamJoined.with(...)` in case your code needs a different type setup.
105105
StreamJoined.with(
106106
Serdes.String(), /* key */
107107
Serdes.String(), /* left value */

0 commit comments

Comments
 (0)