Skip to content

Commit bf3099c

Browse files
committed
review comments
1 parent e1b274a commit bf3099c

File tree

1 file changed

+3
-2
lines changed
  • streams/src/main/java/org/apache/kafka/streams/kstream

1 file changed

+3
-2
lines changed

streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -2403,8 +2403,9 @@ <VT, VR> KStream<K, VR> leftJoin(final KTable<K, VT> table,
24032403
*
24042404
* In contrast to {@link #join(KTable, ValueJoiner)}, there is no co-partitioning requirement between this
24052405
* {@code KStream} and the {@link GlobalKTable}.
2406-
* Also note, that the {@link GlobalKTable} is updated "asynchronously", and thus this operation is inherently
2407-
* non-deterministic.
2406+
* Also note that there are no ordering guarantees between the updates on the left and the right side of this join,
2407+
* since updates to the {@link GlobalKTable} are in no way synchronized.
2408+
* Therefore, the result of the join is inherently non-deterministic.
24082409
*
24092410
* @param globalTable
24102411
* the {@link GlobalKTable} to be joined with this stream

0 commit comments

Comments
 (0)