好吧,现在考虑到我已经问了一个相关的问题,我有点沮丧:
为什么kafka avro console producer不遵守字段的默认值?
如果producer使用旧模式而没有新字段f2,则使用新模式的使用者应接受该字段的默认值,但对于kafka avro console consumer,这一点并不明显:
$ kafka-avro-console-producer --broker-list localhost:9092 --topic test-avro --property schema.registry.url=http://localhost:8081 --property value.schema='{"type":"record","name":"myrecord1","fields":[{"name":"f1","type":"string"}]}'
{"f1": "value3"}
$ kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic test-avro --property schema.registry.url=http://localhost:8081 --property value.schema='{"type":"record","name":"myrecord1","fields":[{"name":"f1","type":"string"},{"name": "f2", "type": "int", "default": 0}]}'
{"f1":"value3"}
我的意思是,好吧,它确实不会抛出异常并由于缺少f2字段而终止,也就是说,它显示了它收到的实际消息,但是它是否应该根据它使用的模式来显示该消息的表示?
以下是架构的两个版本:
curl http://localhost:8081/subjects/test-avro-value/versions/1
{"subject":"test-avro-value","version":1,"id":5,"schema":"{\"type\":\"record\",\"name\":\"myrecord1\",\"fields\":[{\"name\":\"f1\",\"type\":\"string\"}]}"}
curl http://localhost:8081/subjects/test-avro-value/versions/2
{"subject":"test-avro-value","version":2,"id":6,"schema":"{\"type\":\"record\",\"name\":\"myrecord1\",\"fields\":[{\"name\":\"f1\",\"type\":\"string\"},{\"name\":\"f2\",\"type\":\"int\",\"default\":0}]}"}
那么,这是否意味着这样的场景不能用kafka avro控制台测试?
1条答案
按热度按时间xzabzqsa1#
你的制作人已经注册了
value.schema
您已在注册表中指定。无法使用confluent的使用者应用程序为使用者明确定义模式,因为它是基于嵌入在有效负载字节数组中的模式id直接从注册表检索的。