Apache Kafka和汇流模式注册表
我使用的是Azure HDInsight的托管Apache Kafka解决方案，因为不幸的是Azure上没有托管汇流Kafka解决方案。是否可以运行汇合模式注册表并将其连接到HDInsight Apache Kafka集群的代理？
我希望只在单个VM上安装模式注册表，然后使用schema-registry.properties文件中的这一行，将其指向HDInsight集群的代理列表：
kafkastore.bootstrap.servers=明文：//localhost:9092
这样行吗？或者代理必须是合流安装而不是Apache？
共有1个答案
Confluent Platform中的Apache Kafka经纪人是Apache Kafka。因此，是的，您可以自托管模式注册表，并将其从另一个发行版连接到Apache Kafka。
-
我正在了解Confluent的模式注册表，以满足所有模式管理需求。 我不太理解他们的版本控制方法...有一个的概念，我将其视为一个名称空间。据我所知，subject在模式注册表中必须是唯一。 然后是模式id，或者只是，它也是唯一的。 最后，还有一个。 以下是文档中的片段： :此主题的架构版本，每个主题从1开始 :全局唯一的架构版本id，在所有主题中的所有架构中都是唯一的 因此，一旦我想修改特定主题
-
我试图用函数编程（和spring cloud stream）转换来自输入主题的输入AVRO消息，并在输出主题上发布新消息。下面是我的转换函数： 我的spring boot应用程序是以这种方式声明的，并激活了模式注册表客户机： 谢谢你能给我带来的任何帮助。 视CG
-
我希望即使服务器重新启动，也能保持一个具有固定id的模式。 是否可以在模式注册表中保存模式，以便在服务器崩溃后使用相同的id？ 否则，是否有可能在模式注册表服务器启动时用固定的id硬编码一个模式？
-
我正在尝试设置一个Beam管道，以便使用python API读取Kafka的内容。我能够设置消费者配置和主题。如何更新管道以使用合流模式注册表并定义Avro消息值反序列化器？
-
我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别，例如Spring Cloud模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知，即使数据保留在主题上，以防汇合，查询它时仍然会有延迟。但会有重大影响吗？ 我还可以看到，spring云模式注册表
-
我试图使用Confluent_Kafka的AvroProducer类生成Avro格式的消息。Kafka和Schema-Registry在同一个网络中作为3个节点的集群运行。 我得到的是 我没有使用Docker容器。集群由3个独立的VM组成，其中安装和运行Kafka和Registry Schema，所以它也不是独立的。Python代码从具有网络访问和防火墙异常的第四个VM执行。事实上，我可以在没有a