apache-kafka - 将kafka-avro-console-producer与架构注册表中已存在的架构一起使用

Question

我想将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`

Answer 1

对于当前版本的CLI工具

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)"