This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a22fe105444 Update javadoc on split to mention first matching (#17799)
a22fe105444 is described below
commit a22fe105444eabe072e7364e9e2c93c50c74303c
Author: Bill Bejeck <[email protected]>
AuthorDate: Wed Nov 13 11:41:48 2024 -0500
Update javadoc on split to mention first matching (#17799)
Clarify the functionality of split matching on first predicate
Reviewers: Matthias Sax <[email protected]>
---
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
index 516ffb80227..241df1cd3ec 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
@@ -741,7 +741,8 @@ public interface KStream<K, V> {
/**
* Split this stream into different branches. The returned {@link
BranchedKStream} instance can be used for routing
- * the records to different branches depending on evaluation against the
supplied predicates.
+ * the records to different branches depending on evaluation against the
supplied predicates. Records are evaluated against the
+ * predicates in the order they are provided with the first matching
predicate accepting the record.
* <p>
* Note: Stream branching is a stateless record-by-record operation.
* Please check {@link BranchedKStream} for detailed description and
usage example
@@ -752,7 +753,8 @@ public interface KStream<K, V> {
/**
* Split this stream into different branches. The returned {@link
BranchedKStream} instance can be used for routing
- * the records to different branches depending on evaluation against the
supplied predicates.
+ * the records to different branches depending on evaluation against the
supplied predicates. Records are evaluated against the
+ * predicates in the order they are provided with the first matching
predicate accepting the record.
* <p>
* Note: Stream branching is a stateless record-by-record operation.
* Please check {@link BranchedKStream} for detailed description and
usage example
