合流架构注册表超时错误

Question

我正在使用Avro模式向Kafka主题写入数据。起初，一切正常。在avro文件中添加多一个新字段(scan_app_id)后。我正面临这个错误。

Avro文件：{

“type”：“record”,“name”：“initiate_scan”,“namespace”：“avro”,“doc”：“initiate_scan的avro架构注册表”,“fields”：[{“name”：“app_id”,“type”：“string”,“doc”：“3 digit application id”},

{
  "name": "app_name",
  "type": "string",
  "doc": "application name"
},
{
  "name": "dev_stage",
  "type": "string",
  "doc": "development stage"
},
{
  "name": "scan_app_id",
  "type": "string",
  "doc": "unique scan id for an app in Veracode"
 },
{
  "name": "scan_name",
  "type": "string",
  "doc": "scan details"
},
{
  "name": "seq_num",
  "type": "int",
  "doc": "unique number"
},
{
  "name": "result_flg",
  "type": "string",
  "doc": "Y indicates results of scan available",
  "default": "Y"
},
 {
   "name": "request_id",
   "type": "int",
   "doc": "unique id"
 },
  {
    "name": "scan_number",
    "type": "int",
    "doc": "number of scans"
  }   ] }

错误：原因：org.apache.kafka.common.errors.SerializationException：注册Avro架构时出错：{“type”：“record”,“name”：“initiate_scan”,“namespace”：“Avro”,“doc”：“initiate_scan的Avro架构注册表”,“fields”：[{“name”：“app_id”,“type”：{“type”：“string”,“Avro.java.string”：“string”},“doc”：“3位应用程序id”},{“name”：“app_name”,“,”doc“：”扫描次数“}]}

使用timeoutMillis=9223372036854775807 ms关闭Kafka生产者的信息。（org.apache.kafka.clients.producer.kafkaProducer:1017)原因：io.confluent.kafka.SchemaRegistry.client.Rest.Excepthtml" target="_blank">ions.RestClientException：注册操作超时；错误代码：50002位于io.confluent.kafka.schemaregistry.client.rest.restservice.sendHttpRequest（restservice.java:182)位于io.confluent.kafka.schemaregistry.client.rest.restservice.registerschema（restservice.java:203)位于io.confluent.kafka.schemaregistry.client.rest.restservice.registerschema（restservice.java:292)位于Dserializer$wrapper.serialize(extendedserializer.java:65)位于org.apache.kafka.common.serialization.extendedserializer.java:55)位于org.apache.kafka.clients.producer.kafkaproducer.dosend(kafkaproducer.768)位于org.apache.kafka.clients.producer.kafkaproducer.send(kafkaproducer.send(kafkaproducer.745)位于

我查阅了关于50002错误的汇流文档，上面写着

架构应与先前注册的架构兼容。

这是否意味着我不能更改/更新现有架构？

怎么解决这个？

Answer 1

实际上，链接显示50002-Operation timed out。如果它确实是不相容的，答复实际上会这样说。

在任何情况下，如果添加新字段，则需要定义default值。

这样，任何使用较新的模式定义的、正在读取较旧消息的使用者都知道要为该字段设置什么值。

我发现的允许Avro更改的简单列表是Oracle提供的

可能的错误有：

• 添加的字段没有默认值