florin-akermann commented on code in PR #14187:
URL: https://github.com/apache/kafka/pull/14187#discussion_r1291165997
##########
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java:
##########
@@ -2805,7 +2805,7 @@ <VT, VR> KStream<K, VR> leftJoin(final KTable<K, VT>
table,
* For each {@code KStream} record that finds a corresponding record in
{@link GlobalKTable} the provided
* {@link ValueJoiner} will be called to compute a value (with arbitrary
type) for the result record.
* The key of the result record is the same as the key of this {@code
KStream}.
- * If a {@code KStream} input record key or value is {@code null} the
record will not be included in the join
+ * If a {@code KStream} input value is {@code null} the record will not be
included in the join
* operation and thus no output record will be added to the resulting
{@code KStream}.
* If {@code keyValueMapper} returns {@code null} implying no match
exists, no output record will be added to the
* resulting {@code KStream}.
Review Comment:
I agree, it is more concise.
Regarding the left-join - yes, I adjusted that one too.
--
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
