Kafka Streams 将新源添加到正在运行的应用程序答案

【问题标题】：Kafka Streams Add New Source to Running ApplicationKafka Streams 将新源添加到正在运行的应用程序
【发布时间】：2019-12-17 04:55:10
【问题描述】：

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

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

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

是否可以在不关闭应用的情况下添加源主题？

【问题讨论】：

标签： apache-kafka-streams

【解决方案1】：

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

【讨论】：