Avro架构GenericRecord缺少键

Question

我使用Avro模式动态地从C#应用程序生成消息到Kafka集群，使用汇合的Kafka客户机。在编译时不知道数据类型，因此我使用avro.generic命名空间中的GenericRecord类，如下所述:https://www.confluent.io/blog/decoupling-systems-with-apache-kafka-schema-registry-and-avro/。

但是，我有一个问题--如果模式有一个字段可以包含null值，仍然需要使用add方法将该字段添加到GenericRecord中，将null作为值。我的应用程序不知道哪些字段可以为空，我认为不应该为空--因为这违反了模式中可为空字段的目的。

Avro架构：

{
  "namespace": "Test",
  "type": "record",
  "doc": "Test bool type",
  "name": "BoolType",
  "version": "1",
  "fields": [
    {
      "name": "Data",
      "type": [ "null", "boolean" ],
      "default": null
    },
    {
      "name": "Source",
      "type": "string"
    }
  ]
}

C#代码：

var valueRecord = new GenericRecord( valueAvroSchema );
valueRecord.Add( "Data", null );
valueRecord.Add( "Source", "Test app .NET" );

var messageToSend = new Message<GenericRecord, GenericRecord>
{
   Key = keyRecord,
   Value = valueRecord
};

await _producer.ProduceAsync( _topicName, messageToSend );

如果行：

valueRecord.Add( "Data", null );

不存在，则ProduceAsync方法抛出confluent.kafka.ProduceException，如下面的屏幕截图所示。

是否有任何方法可以自动填充GenericRecord中可以为null的字段？如果我必须用缺省值填充字段，这也适用。

有没有什么方法可以用标准的方式来完成，或者我需要编写自己的代码来读取模式，如果有任何可为空的字段没有被我的应用程序设置，那么在发布之前在结尾处添加这些字段？

谢谢你！

Answer 1

Avro默认值仅与消费者相关。制作者必须始终设置每个字段