mjsax commented on code in PR #18778:
URL: https://github.com/apache/kafka/pull/18778#discussion_r1940551476
##########
streams/src/main/java/org/apache/kafka/streams/Topology.java:
##########
@@ -617,7 +600,9 @@ public synchronized <K, V> Topology addSink(final String
name,
*
* @throws TopologyException
* if the provided processor name is not unique, or
- * if a parent processor/source name is unknown
+ * if a parent processor/source name is unknown or specifies a sink
+ *
+ * @see org.apache.kafka.streams.processor.api.ContextualProcessor
ContextualProcessor
Review Comment:
Think we should point this one out.
Did not link to `FixedKeyProcessor` as it's not really useful for the PAPI
-- it's more of a DSL think (even if it's part of `api.*` package.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
