什么模式格式支持Kafka REST v3？
什么模式格式支持Kafka REST v3？
提问于 2021-10-27 08:23:55
我发现教程的教程模式版本ref在kafka version3中不起作用。
此外，如果我试图通过cp rest- v2发送相同的教程，而不是cp rest:6.2.1，而不是cp rest:6.1.0，那么我所收到的结果也是相同的。
我推导出的模式-注册表不依赖于kafka-rest版本-的假设是正确的吗？
教程：
https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/rest-proxy.html#basic-producer-and-consumer 姓名-记录
信息：
{
"key": {
"subject_name_strategy": "TOPIC_NAME",
"schema_id": 8,
"data": 1000
},
"value": {
"data": {
"countInfo": {
"count": 0
}
}
}
}答案是：
"Error when fetching schema version. subject = test-key, schema = [{\"type\":\"record\",\"name\":\"countInfo\",\"fields\":[{\"name\":\"count\",\"type\":\"long\"}]}]"回答 1
Stack Overflow用户
发布于 2022-06-19 23:26:52
使用7.1.0版本，它可以工作
关键模式：
{"type": "string"}值模式：
{
"type":"record",
"name":"countInfo",
"fields":[
{
"name":"count",
"type":"long"
}
]
}import requests
data = {
"key": {
"data": "AAAAAA"
},
"value": {
"data": {"count": 4546}
}
}
print(data)
response = requests.post(
f"{rest_proxy}/v3/clusters/toto/topics/tata/records",
headers={"Content-Type": "application/json"},
json=data)
print(response.reason)
print(response.text)给
{'key': {'data': 'AAAAAA'}, 'value': {'data': {'count': 4546}}}
OK
{"cluster_id":"toto","topic_name":"tata","partition_id":1,"offset":32,"timestamp":"2022-06-19T23:22:05.481Z","key":{"type":"AVRO","subject":"tata-key","schema_id":1,"schema_version":1,"size":12},"value":{"type":"AVRO","subject":"tata-value","schema_id":2,"schema_version":1,"size":7}}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/69735186
复制相关文章
相似问题
腾讯云开发者
