我的本地dev-Kafka模式注册表正在运行,我能够从我的生产者发布模式并获得一个ID。我使用自动注册=false,与我的生产服务器相同。但我对模式进行了更新,添加了一个字符串。
+ {
+ "name":"testkey",
+ "type":{
+ "type":"string",
+ "avro.java.string":"String"
+ },
+ "doc":"test test test",
+ "default":""
}
POST以404失败
org.apache.kafka.common.errors。SerializationException:检索Avro架构时出错:由io.confluent.kafka.schemaregistry.client.rest.exceptions引起。RestClientException:未找到架构;错误代码:40403
我不知道为什么,我的本地代码中的模式与我发布到服务器的模式相同。
以下是我发布模式的方式:
jq.|{schema:tojson}./mySchema。avsc |卷曲-X柱html" target="_blank">http://localhost:8081/subjects/mySchema/versions-H“内容类型:应用程序/json”-d@-
故障日志:[2021 03月05日10:39:14690]信息172.19.0.1---[2021年3月5日10:39:14 0000]“POST/subjects/mySchema?deleted=false HTTP/1.1”404 49 62(io.confluent.rest-utils.requests)
我正在使用合流v5.1.2
希望你能帮我提建议。
这是用于注册模式的命令:jq '. | {模式:tojson}'./mySchema.avsc|curl-X POSTlocalhost:8081/subjects/mySchema/versions-H"Content-Type: Application/json"-d @- – --
虽然上一节大概介绍了图 7.12 中表单的 HTML 结构(参见代码清单 7.15),但并没涉及什么细节,其实注册失败时才能更好地理解这个表单的作用。本节,我们会在注册表单中填写一些无效的数据,提交表单后,页面不会转向其他页面,而是返回“注册”页面,显示一些错误消息,如图 7.14 中的构思图所示。 图 7.14:注册失败时显示的页面构思图 7.3.1 可正常使用的表单 回顾一下 7.1.2 节的
我正在尝试使用docker compose设置本地kafka connect堆栈,但我的scala producer出现问题,它应该使用schema registry向kafka主题发送avro消息。 在我的生产者(scala)代码中,我执行以下操作: 我的docker-comment脚本写着: 编辑:现在架构注册表似乎已启动: 但在此之前,在脚本的执行过程中,我得到: 这可能是因为依赖性问题吗?
附注:我没有张贴整个控制器。这里只包括http请求部分。
我有一个简单的spring启动应用程序,其中有一个兔子发送器和一个接收器。我想编写一些接收器测试,其中我以Junit类规则(RabbitContainerRule)运行rabbitmq docker实例,然后使用rabbitTemplate发送消息,测试验证接收器是否接收到相同的消息。但我得到了以下例外: 如果使用管理控制台在docker实例中手动创建队列(通过在断点处停止),则测试通过。 另外,
这一条给出: 这个: 我想做的是避免为所有测试编写完整的jsons,如果我可以跳过所有“”和{},将会更快。我的方法正确吗?
我正在开发一个脚本,以访问图形API阅读我们的广告中的所有用户。我正在通过以下方式使用AXIOS执行一个请求: 然而,这失败了,因为: client_id=535FB089-9FF3-47B6-9BFB-4F1264799865&scope=https%3a%2f%2fgraph.microsoft.com%2f.default&client_secret=qwgdyamab0yskul1qkv5