0

我们正在使用 Confluent Rest Proxy 与 Kafka 通信，需要测试各种数据。我们正在使用 Rest Proxy 来允许供应商与我们的 Kafka 系统进行通信。

Avro 模式中的一个字段具有十进制的逻辑类型。为了简单起见，让我们假设这里显示的模式：

{
  "fields": [
    {
      "name": "fieldName",
      "type": "string"
    },
    {
      "name": "amount",
      "type": {
        "logicalType": "decimal",
        "precision": 16,
        "scale": 2,
        "type": "bytes"
      }
    }
  ],
  "name": "Sample",
  "namespace": "com.test.sample",
  "type": "record"
}

通过 Java 生产者编写主题很容易，使用 Avro 工具生成适当的类文件。但是当尝试使用 Rest Proxy 时，我们必须传递如下值：

{"value_schema_id":132,"records": [{"value":{"fieldName":"Field Name","amount":"\u0001ã"}}]}

这是从通过 Java 生产者创建的记录中复制的，然后从主题中下载。但在amount现场，我们希望能够传递一个值，例如123.45. 我们主要使用 Postman 来发送数据。有没有办法使用逻辑十进制字段来做到这一点，而不必先创建和序列化数据以查看表示，例如\u0001ã？

4

0 回答 0