如何在一个Kafka Streams应用程序中连接到多个集群？
这是否意味着我的整个应用程序只能连接到单个Kafka集群，或者KafkaStreams的每个实例只能连接到单个集群？
我可以创建多个连接到不同集群的具有不同属性的KafkaStreams实例吗？
共有1个答案
这意味着单个应用程序只能连接到一个集群。
- 不能从群集a读取主题并将计算结果写入群集B。
- 不可能使用同一个实例从两个不同的群集读取两个主题。
我可以创建多个连接到不同集群的具有不同属性的KafkaStreams实例吗？
-
也就是说，我想创建应用程序，然后让这些应用程序访问一个项目的特定Firebase数据库。 查看Firebase Android文档，我找不到一种方法来使用下面的方法将数据发送到另一个项目中的另一个Firebase数据库，但其中的引用是另一个项目的。
-
问题内容： 我正在尝试编写一个多线程Python应用程序，其中在线程之间共享一个SQlite连接。我无法使它正常工作。真正的应用程序是一个小巧的Web服务器，但是以下简单代码演示了我的问题。 为了成功运行下面的示例代码，我需要进行哪些更改？ 当我在THREAD_COUNT设置为1的情况下运行此程序时，它可以正常工作，并且数据库已按预期进行更新（即，字母“ X”被添加到SectorGroup列的文本
-
我的主文件app.js连接到userDB我想添加第二个数据库postsDB 常量mongoose=require（“mongoose”）； 常量app=express()； mongoose.set（“UseCreateIndex”,true）；mongoose.set（“UseUnifiedTopology”,true）； Mongoose.connect（“MongoDB：//localhos
-
这可能不是典型的设置，但由于更高的决策，我们最终在一个应用程序中有多个 kafka 集群，每个集群有多个主题，每个集群可能具有不同的序列化策略。Json/avro.avro可能与融合的架构注册表一起使用，或者使用单个对象编码。 好吧，我通过构建自己的抽象和注册中心，分析配置并手动创建大部分内容，以某种方式实现了它，但我觉得我需要在几个地方多次重复主题名称、模式注册url等内容，以便创建所有需要的b
-
Google在这里有一个很好的页面展示了如何这样做：https://developer.android.com/distribute/tools/promote/linking.html 基本上，使用这段代码，它将打开Play Store到新apps页面： 我错过了什么？我肯定它非常简单，也许我需要进口的东西。 解决方案：导入Uri类是一个问题。我仍然不确定新的热键是什么来导入它。Apple-Sh
-
在我的spring boot应用程序中，我使用Oracle作为数据库。数据库具有不同的模式。我有一个要求，列出所有模式，并在循环中使用该模式连接到数据库，并对表执行一些查询。我看到一些博客通过在应用程序中定义数据源来连接到不同的模式。财产。我不想这样做，因为我已经定义了大约40个模式，我不想定义那么多的数据源。