问题

我想使用带有模式注册表的kafka-avro-console-producer。我有大型模式（超过10k字符），不能将它们作为命令行参数粘贴。除此之外，我想直接使用模式注册表，以便可以使用特定的模式ID。

我在考虑这样的方法，但它不起作用：

kafka-avro-console-producer \
 --broker-list <broker-list> \
 --topic <topic>  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema=`curl http://localhost:8081/schemas/ids/419`

kafka-avro-console-producer \
 --broker-list <broker-list> \
 --topic <topic>  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema=`curl http://localhost:8081/schemas/ids/419`

答案1

得分: 22

## 对于当前版本的CLI工具

```shell
kafka-avro-console-producer \
 --broker-list <broker-list> \
 --topic <topic>  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema.id=419

对于旧版本

您需要使用jq从API请求中提取模式，例如

value.schema="$(curl http://localhost:8081/schemas/ids/419 | jq -r .schema)"

<details>
<summary>英文:</summary>

## For the current version of the CLI tool

```shell
kafka-avro-console-producer \
 --broker-list &lt;broker-list&gt; \
 --topic &lt;topic&gt;  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema.id=419

For older version

You'll need to extract the schema from the API request using jq, for example

value.schema="$(curl http://localhost:8081/schemas/ids/419 | jq -r .schema)"

答案2

得分: 8

你可以使用属性 value.schema.id：

kafka-avro-console-producer \
 --broker-list <broker-list> \
 --topic <topic>  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema.id=419

kafka-avro-console-producer \
 --broker-list <broker-list> \
 --topic <topic>  \
 --property schema.registry.url=http://localhost:8081 \
 --property value.schema.id=419