使用模式注册表的Spring Kafka Producer测试
我正试图使用SpringKafka为我的生产者应用程序及其嵌入式Kafka服务器编写测试。
然而，我的应用程序也使用合流模式注册表，我想知道SpringKafka是否为模式注册表提供了一些嵌入式服务器？
或者有没有更好的方法来使用模式注册表进行Spring Kafka测试？
共有1个答案
Spring Kafka没有提供模式注册表；它没有Apache许可；但是，您可以将外部汇合注册表与嵌入的kafka代理一起使用。
Spring Cloud Stream在这里确实有一个简单的注册表文档。
它正在被转移到自己的项目中。
-
我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别，例如Spring Cloud模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知，即使数据保留在主题上，以防汇合，查询它时仍然会有延迟。但会有重大影响吗？ 我还可以看到，spring云模式注册表
-
我正在尝试使用Confluent schema registry，下面是我在Github中找到的一些示例(https://github.com/gAmUssA/springboot-kafka-avro). 当消费者和生产者与模型共享相同的命名空间而不是其工作时。 当使用者位于具有不同名称空间但具有相同类（名称和属性方面）的不同项目中时，它不工作。 合流Avro反序列化程序可以使用正确的值反序列化
-
我正在了解Confluent的模式注册表，以满足所有模式管理需求。 我不太理解他们的版本控制方法...有一个的概念，我将其视为一个名称空间。据我所知，subject在模式注册表中必须是唯一。 然后是模式id，或者只是，它也是唯一的。 最后，还有一个。 以下是文档中的片段： :此主题的架构版本，每个主题从1开始 :全局唯一的架构版本id，在所有主题中的所有架构中都是唯一的 因此，一旦我想修改特定主题
-
我有一个Kafka主题，我想用AVRO数据（目前是JSON）来填充它。我知道“正确”的方法是使用模式注册表，但出于测试目的，我想让它在没有它的情况下工作。 因此，我将AVRO数据作为数组[字节]发送，而不是常规的Json对象： 模式是在每个数据中启动的；我如何使它与kafka-connect一起工作？kafka-connect配置目前表现出以下属性（数据作为json.gz文件写入s3），我想编写P
-
我使用来自Confluent的Kafka Connect来使用Kafka流并以拼花格式写入HDFS。我正在1个节点中使用架构注册表服务，它运行良好。现在我想将模式注册表分发到集群模式以处理故障转移。关于如何实现这一点的任何链接或片段都将非常有用。
-
我正在实现一个生成Kafka消息的过程，每个消息都应该有由模式注册表验证的模式。为了开发，我使用docker运行kafka和模式注册表，我的模式由模式注册表ui进行注册。 看起来我的模式没有被验证或者我缺少一些配置。我的生产者类有以下代码： 大多数时候，我会收到一个错误，如“Schema not found”，当没有引发此异常时，我的消息不会被验证，它只是将消息发送到另一个主题。 是否缺少任何类型