0

我透露教程中的教程模式版本参考在kafka version3 中不起作用。

另外，如果我尝试通过 kafka-rest v2 从 cp-kafka-rest:6.2.1 而不是 cp-kafka-rest:6.1.0 发送相同的教程，我会收到相同的结果

我得出的一个假设是模式注册表不依赖于 kafka-rest 版本——它正确吗？

教程：

https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/rest-proxy.html#basic-producer-and-consumer https://docs.confluent.io/platform/current/kafka -rest/api.html#post--clusters-cluster_id-topics-topic_name-records

消息：

{
  "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\"}]}]"
4

0 回答 0