当avro模式由另一个模式作为可选字段组成时，反序列化问题

Question

我们定义了一个avro模式，并使用代码生成器在Java和

这是我们用来从avro模式生成java类的代码生成器

https://plugins.gradle.org/plugin/com.commercehub.gradle.plugin.avro

和使用

现在，我尝试使用c#生产者将消息发布到Kafka上，并尝试使用java消费者消费它。这适用于大多数数据类型，但以下合同“OptionalComposition”除外。

{
 "type": "record",
 "name": "OptionalComposition",
 "doc": "Contract to test composition with optional field ",
 "namespace": "com.abc.avro.contracts",
 "fields": [
{ "name": "partOf", "type": ["null", "com.abc.avro.contracts.Reference"], "default": null }
]
 }

{
 "type": "record",
 "name": "Reference",
 "namespace": "com.abc.avro.contracts",
 "fields": [
{ "name": "identifier", "type": "string" }
,
{ "name": "name", "type": "string" }
]
 }

Answer 1

我能够通过使用我的gradle插件设置一个额外的属性（stringType到“CharSequence”）来解决这个问题，以从. avsc文件生成我的. java文件。

以下是我们用于从.avsc文件生成.java文件的gradle插件的链接

https://plugins.gradle.org/plugin/com.commercehub.gradle.plugin.avro

以下是我正在谈论的物业的文档 https://github.com/davidmc24/gradle-avro-plugin#stringtype

这是我用来生成POJOs的gradle任务。avsc文件

task generateContracts(type: GenerateAvroJavaTask, dependsOn: clearContracts) {
    fieldVisibility = "PRIVATE"
    dateTimeLogicalType = 'JSR310'
    outputCharacterEncoding = "UTF-8"
    stringType = "CharSequence"
    source("src/main/resources/avro")
    outputDir = file("src/main/java/")
}

通过添加stringType=“CharSequence”，我们要求代码生成器生成字符串类型属性，以将java.lang.CharSequence作为数据类型，而不是java.lang.String