当前位置: 首页 > 知识库问答 >
问题:

在一个spring boot应用程序中使用多个不同的kafka服务器的方法是什么?

乔伯寅
2023-03-14

也许这很奇怪,我只需要在一个配置文件中添加bootstrap.serverskafka.properties就可以了?找不到任何关于那件事的信息...

共有1个答案

沙靖琪
2023-03-14

如果您的所有kafka服务器都属于同一个集群,那么为客户机配置一个配置就足够了。Kafka服务器之间进行内部通信,并在集群中共享所有主题的最新元数据,即使主题不位于特定的服务器上。

因此,在定义bootstrap.server时,只提到其中一个服务器就足够了。在该配置的描述中对此进行了更详细的解释:

“用于建立与Kafka群集的初始连接的主机/端口对列表。无论此处指定哪些服务器进行引导,客户端都将使用所有服务器-此列表只影响用于发现完整服务器集的初始主机。此列表的形式应为Host1:port1、Host2:port2,...由于这些服务器只是用于初始连接以发现完整的群集成员资格(可能会动态更改),因此此列表不必包含完整的服务器集(不过,在服务器关闭的情况下,您可能需要多个服务器)。”

 类似资料:
  • 这可能不是典型的设置,但由于更高的决策,我们最终在一个应用程序中有多个 kafka 集群,每个集群有多个主题,每个集群可能具有不同的序列化策略。Json/avro.avro可能与融合的架构注册表一起使用,或者使用单个对象编码。 好吧,我通过构建自己的抽象和注册中心,分析配置并手动创建大部分内容,以某种方式实现了它,但我觉得我需要在几个地方多次重复主题名称、模式注册url等内容,以便创建所有需要的b

  • 我在dockerized应用程序和Memcached上遇到了一个问题,要存储一些值,显然,当a启动一个运行Spymemcached客户端的新Docker实例时,所有存储在缓存中的数据都是无效的,所以如果我之前在节点1的缓存中存储了一些值,然后启动节点2,这些值将从Memcached服务器中清除,最后如果a在节点1上再次存储相同的值,并在节点2上查询,它们将共享到两个节点之外,而不清除数据。是预期的

  • 问题内容: 我是Spring的新手,我想知道是否可以在同一应用程序中使用多个事务管理器? 我有两个数据访问层-一个用于两个数据库。我想知道,你如何在一个层使用一个事务管理器,而在另一层使用另一个事务管理器。我不需要在两个数据库之间都执行事务。但是我确实需要分别在每个数据库上执行事务。我创建了一个图像来帮助概述我的问题: 这是我的应用程序上下文配置: 这是使用此配置的示例: 因此,对于帐户存储库,我

  • 问题内容: 我正在处理一个系统,该系统在其自己的JVM中为每个客户运行Java应用程序。现在,我们有大约六个专用服务器,它们总共运行近100个JVM,以及用于管理这些JVM的自定义脚本集。此设置实际上已经表明了它的年龄:管理许多JVM已成为监视/管理的噩梦,并且我们一直在处理堆大小调整问题。我们想采用一种更现代的方法,并在每台物理计算机的单个应用服务器中运行一堆应用程序。但是,将应用程序保持隔离确

  • 我想在我们的Webjob中获得应用的见解,我使用了这个nuget软件包: https://github.com/azure/azure-webjobs-sdk/wiki/application-insights-integration 当我们在同一个azure服务器(web应用程序)上运行两个web作业时,我们看不到web作业的分离,所以我们不知道是哪个web作业占用了资源?还有什么我能做的吗?还

  • 我用开发了一个web应用程序,它运行良好。 现在我正在尝试为其他开发人员设置相同应用程序的更多实例。因此,现在我有9个实例(dev01-dev09)。我已经为每个dev实例创建了数据库并设置了文件,除了之外,它们都运行良好。例如,由创建的消息队列,但它是由dev02的使用者处理的(它应该由dev01处理)等等。 [更新于美国东部时间1月23日凌晨4点]为了尝试一下,我将queue_options中