以Kafka Avro文件格式向架构注册表添加新的架构/主题
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data '{"schema" : {"type":"record","name":"myrecord","fields":[{"name":"f1","type":"string"}]}' http://localhost:8081/subjects/avro-test/versions/
共有1个答案
架构需要字符串转义
例如，开始
POST -d'{"schema": {\"type\":\"record\"
如果可以，那么安装jq工具并创建一个AVSC文件，这将会有所帮助-请参见我在这里的评论
-
嘿，我想将ConFluent模式注册表与Avro Serializers一起使用：留档现在基本上是说：不要为多个不同的主题使用相同的模式 谁能解释一下原因吗？我重新搜索了源代码，它基本上将模式存储在Kafka主题中，如下所示（topicname，magicbytes，version- 因此，除了冗余之外，我看不到多次使用模式的问题？
-
我有一个docker容器运行AWS弹性容器服务（Fargate）中的confluentinc/cp模式注册表：5.5.0。只有一个容器正在运行。通过该模式注册表获取当前注册模式的API调用正在工作（例如，
-
对于跨网络汇流平台，我们有一个kafka集群在Premise上，另一个在AWS上，其中数据使用mirror Maker从on-prem复制到AWS。这两个集群都独立于它们自己的模式注册表、rest代理和Connect，这两个集群都有不同的生产者和消费者集，并且选择的主题在集群之间被镜像。 部署schema-registry的最佳实践应该是什么？我们是否应该在on-prem和AWS上有一个主服务器（
-
我正在尝试从模式注册表中检索给定kafka主题的模式主题版本。我可以使用成功发布新版本，但我不确定如何检索版本。我在下面尝试使用curl请求，但结果立即命中-1（空）。 我如何修复这个GET请求，或者更好的是，我应该如何使用模式注册中心来检索一个模式？
-
这里是我的docker容器： 我的制作人（用Kolin写成） 我的Avro架构： 状态：打开 消息：发送的邮件。 所以我把它发送给KAFKA，在connect（jdbc sink postgres）中，我只将消息（客户端）的属性作为Fields.whitelist而不获得命令id或状态。 4-https://github.com/rodrigodevelms/kafka-registry/blob
-
我试图使用Avro模式向我的经纪人发送消息，但“我总是收到错误： 2020-02-01 11:24:37.189[nioEventLoopGroup-4-1]错误应用程序-未经处理：POST-/api/orchestration/org。阿帕奇。Kafka。常见的错误。SerializationException:注册Avro架构时出错：io导致“字符串”。汇合的。Kafka。阴谋论。客户Rest
-
我有一个XSD模式，根文档是：
-
我正在尝试使用docker compose设置本地kafka connect堆栈，但我的scala producer出现问题，它应该使用schema registry向kafka主题发送avro消息。 在我的生产者（scala）代码中，我执行以下操作： 我的docker-comment脚本写着： 编辑：现在架构注册表似乎已启动： 但在此之前，在脚本的执行过程中，我得到： 这可能是因为依赖性问题吗？