我正在探索将ITSM系统与Kafka集成的各种选择。这需要Protobuf消息通过rest代理API发送到Kafka。
我遵循了以下两篇文章,并设置了请求主体和标题。
https://quachtd.com/using-kafka-rest-proxy-with-protobuf/
在Confluent上,我创建了一个主题和一个测试模式。虽然我能够通过JSON生成主题下的消息,但我无法生成Protobuf消息。
我甚至无法测试‘GET’方法,因为我无法找到SchemaRegistryHost和端口。如何从汇合控制台获得这些详细信息?主题-值/版本/1
虽然我手动获取架构ID并在输入中提供它,但我收到了消息“{”error_code“:405,”message“:”HTTP405方法不允许“}”。这让我想到,在Schema上是否需要对“POST”方法进行操作。
另外,由于这不是JSON,我想知道我是否不能在Postman中测试这一点。如果有可能,我如何测试它,否则,其他什么工具可以帮助我执行测试?
发布于 2022-09-18 17:08:51
在向注册表添加架构之前,必须将模式设置为导入。
模式参数定义架构上允许的操作。
IMPORT
READONLY
READWRITE第一个允许导入模式并指定id和版本。
您可以为所有主题或特定主题设置模式。要在Schema注册表上启用模式更改,必须在模式注册表属性文件中设置以下属性,然后才能启动该属性:
mode.mutability=true
使用curl,您可以使用以下命令:
curl -X PUT -H "Content-Type: application/json" http://{SchemaRegistryHost}:{SchemaRegistryPort}/mode --data '{"mode": "IMPORT"}'https://stackoverflow.com/questions/73763311
复制相似问题