我在不同的机器上运行具有不同kafkastore.topic
的相同kafka代理集群的两个模式注册表。
kafkastore.topic=_DEV_schemas
kafkastore.topic=_QA_schemas
该实例没有任何问题,运行良好。但是当我试图在DEV上创建一个新模式时,问题就开始了,它会转到QA。所以
是否不可能为同一个代理集群运行两个不同的模式注册表?
谢谢
如https://stackoverflow.com/a/58571410/5650306所述
正在设置环境变量schema.registry.group。两个架构注册表服务器的id。https://docs.confluent.io/platform/current/schema-registry/installation/config.html#schema-注册表组id
这是可能的。
您需要将主题和侦听器地址设置为不同的值
我试图针对同一个kafka和zookeeper集群装载两个kafka模式注册表实例。但谢马一家的情况越来越复杂。当运行这两个注册表时,如果我使用api“kafka schema registry”注册一个架构,它似乎是在“schema registry ui other”中创建的,而不是像预期的那样显示在“kafka schema registry ui”中。我的配置是: 不可能有两个分离的模式注
在我的应用程序中,我有以下代码可注册到GCM服务: 当我运行这段代码时,我在服务器中看到我的设备用2个不同的注册了两次,当服务器发送推送时,设备收到2条消息。 这是正常的事情吗?有没有办法确保只有一个?
我的客户机/服务器上的推送通知设备注册管理有一个小问题。 同样,这里的问题是,我有两个或更多的注册ID都可以工作(如果我旧的一个在尝试从服务器发布消息时不工作,这不会有问题,因为我可以简单地清理它)。
我使用来自Confluent的Kafka Connect来使用Kafka流并以拼花格式写入HDFS。我正在1个节点中使用架构注册表服务,它运行良好。现在我想将模式注册表分发到集群模式以处理故障转移。关于如何实现这一点的任何链接或片段都将非常有用。
在Java9上使用Spring5。。。。 甚至不确定这是可能的。有一个非常简单的类: 和都只需要几个配置属性(即一些.queue)就可以工作。要注册(通过或)Exchangebean的多个实例,但带有前缀配置属性。在注册bean时是否仍要更改属性定义?
我想在同一个网络中为开发人员和QA(或prod和staging)设置两个集群。每个集群由几个节点组成。节点将在网络上可达,我想消除与开发节点的QA节点群集。为此,我应该更改什么,下面是我的配置。 是否需要更改不同的群集连接名称、广播组和发现组?