Skip to content
代码片段 群组 项目
未验证 提交 025e47b8 编辑于 作者: Tom Kaszuba's avatar Tom Kaszuba 提交者: GitHub
浏览文件

KAFKA-13963: Clarified TopologyDescription JavaDoc for Processors API forward() calls (#12293)

Reviewers: Matthias J. Sax <matthias@confluent.io>
上级 d654bc1b
No related branches found
No related tags found
无相关合并请求
......@@ -30,6 +30,7 @@ import java.util.regex.Pattern;
* In contrast, two sub-topologies are not connected but can be linked to each other via topics, i.e., if one
* sub-topology {@link Topology#addSink(String, String, String...) writes} into a topic and another sub-topology
* {@link Topology#addSource(String, String...) reads} from the same topic.
* Message {@link ProcessorContext#forward(Object, Object) forwards} using custom Processors and Transformers are not considered in the topology graph.
* <p>
* When {@link KafkaStreams#start()} is called, different sub-topologies will be constructed and executed as independent
* {@link StreamTask tasks}.
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册