This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a commit to branch 3.9
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.9 by this push:
new a6c3576be38 Update javadoc on split to mention first matching (#17799)
a6c3576be38 is described below
commit a6c3576be3885321c32d77664ebf1a5aa20d838b
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 39b5f1a1374..03f039c428a 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
@@ -785,7 +785,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
@@ -796,7 +797,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
