首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >使用Rest代理API生成Protobuf消息

使用Rest代理API生成Protobuf消息
EN

Stack Overflow用户
提问于 2022-09-18 13:48:50
回答 1查看 62关注 0票数 0

我正在探索将ITSM系统与Kafka集成的各种选择。这需要Protobuf消息通过rest代理API发送到Kafka。

我遵循了以下两篇文章,并设置了请求主体和标题。

https://quachtd.com/using-kafka-rest-proxy-with-protobuf/

https://docs.confluent.io/platform/current/kafka-rest/quickstart.html#produce-and-consume-protobuf-messages

在Confluent上,我创建了一个主题和一个测试模式。虽然我能够通过JSON生成主题下的消息,但我无法生成Protobuf消息。

我甚至无法测试‘GET’方法,因为我无法找到SchemaRegistryHost和端口。如何从汇合控制台获得这些详细信息?主题-值/版本/1

虽然我手动获取架构ID并在输入中提供它,但我收到了消息“{”error_code“:405,”message“:”HTTP405方法不允许“}”。这让我想到,在Schema上是否需要对“POST”方法进行操作。

另外,由于这不是JSON,我想知道我是否不能在Postman中测试这一点。如果有可能,我如何测试它,否则,其他什么工具可以帮助我执行测试?

在这里输入图像描述

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2022-09-18 17:08:51

在向注册表添加架构之前,必须将模式设置为导入。

模式参数定义架构上允许的操作。

代码语言:javascript
复制
IMPORT
READONLY
READWRITE

第一个允许导入模式并指定id和版本。

您可以为所有主题或特定主题设置模式。要在Schema注册表上启用模式更改,必须在模式注册表属性文件中设置以下属性,然后才能启动该属性:

mode.mutability=true

使用curl,您可以使用以下命令:

代码语言:javascript
复制
curl -X PUT -H "Content-Type: application/json" http://{SchemaRegistryHost}:{SchemaRegistryPort}/mode --data '{"mode": "IMPORT"}'
票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/73763311

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档