Kafka流向正在运行的应用程序添加新源
是否可以将另一个源主题添加到正在运行的kafka streams java应用程序的现有拓扑中。基于javadoc(https://kafka.apache.org/23/javadoc/org/apache/kafka/streams/kafkastreams.html)，我猜答案是否定的。
我的用例：REST api调用触发一个新的源主题应该由一个现有的处理器处理。源主题存储在数据库中并用于生成拓扑。
我相信唯一的选择是关闭应用程序，并重新启动它，允许新的主题被拾取。
有没有可以在不关闭APP的情况下添加源主题的选项？
共有1个答案
您不能在程序运行时修改它。正如您指出的，要更改任何内容，您需要停止程序并创建一个新的拓扑。根据您的程序和更改，您可能需要在重新启动应用程序之前重置它。参见https://docs.confluent.io/current/streams/developer-guide/app-reset-tool.html
-
我们有一个网络应用程序，允许用户上传照片，上传后将显示在指定页面上。上传模块将图像放在分解的war目录中，例如，这样一旦上传图像，就可以立即查看，如。 这是一个应用服务器，但事实证明，我们要把这个应用部署到两个负载平衡的服务器上。因此，我编写了一个快速文件同步模块，每当用户上传图像时，它都会使用FTP在服务器之间同步文件。基本上，当用户在上上传图像时，我会立即通过FTP将其复制到。 编辑（添加上传
-
我有一个java应用程序，需要部署在weblogic服务器中。我目前正在为该应用程序制作ear文件。我的ear文件中有一个ejb jar。我想将log4j2 jar添加到此应用程序中。所以我的文件夹结构是 目前，我已经将JAR放在APP-INF文件夹/lib和META-INF/application中。xml我把JAR放在了模块中。这是我的申请表。xml 但它不接受log4j罐子。有什么解决方案吗
-
我已经将 firebase-core 添加到我的项目中进行分析，但从那时起我的应用程序就没有响应了。 这是我正在使用的gms的类路径： 这是我用于Firebase的依赖项： 此外，我还添加了到我的构建gradle文件的底部。 在我的应用程序类中，我只是初始化FirebaseAnalytics： 这是我从日志中得到的错误： 错误指向我的应用程序类的第84行，即Firebase Analytics初始
-
问题内容： 到目前为止，我还没有找到在Drools 6.0.0中将规则添加到正在运行的KieSession的最佳方法（即以最小的开销），而仍然将我的事实保留在KieSession中。在Drools 5中，当更改KBase时更新了KSession，但对于Drools 6而言却并非如此，因为我的规则未在KieBase中创建。有没有一种方法可以替换整个KieFileSystem中的整个KieModule
-
我正在以独立模式运行Spark群集。 我已使用以下选项提交了群集模式下的Spark应用程序： 使作业具有容错性。 现在我需要保持集群运行但停止应用程序运行。 我尝试过的事情： 停止集群并重新启动它。但是当我这样做时，应用程序会恢复执行。 使用了名为DriverWrapper的守护进程的Kill-9，但之后工作再次恢复。 我还删除了临时文件和目录并重新启动了集群，但作业再次恢复。 所以正在运行的应用
-
这与我的问题相反，在OpenDayLight中安装自定义功能或模块？。我希望使用Hello World应用程序并添加以下功能的： ODL-RestConf ODL-MDSal-APIDOCS ODL-openflowplugin-flow-services ODL-openflowplugin-app-table-miss-enforcer ODL-OpenFlowPlugin-NXM-Exten