Kafka 流将新源代码添加到正在运行的应用程序



是否可以将另一个源主题添加到正在运行的 kafka 流 java 应用程序的现有拓扑中。 基于javadoc(https://kafka.apache.org/23/javadoc/org/apache/kafka/streams/KafkaStreams.html(,我猜答案是否定的。

我的用例: REST API 调用触发器 新的源主题应由现有处理器处理。 源主题存储在数据库中,用于生成拓扑。

我相信唯一的选择是关闭应用程序并重新启动它,以便选择新主题。

是否有任何选项可以在不关闭应用程序的情况下添加源主题?

您不能在程序运行时对其进行修改。正如您所指出的,要更改任何内容,您需要停止程序并创建一个 新Topology.根据您的程序和更改,您可能实际上需要在重新启动应用程序之前重置应用程序。参看 https://docs.confluent.io/current/streams/developer-guide/app-reset-tool.html

相关内容

最新更新