流式应用程序，正在注册的模式与主题的早期模式不兼容

Question

我有一个源连接器，可以推送到新创建的主题。“key.converter”和“value.converter”未配置，因此转换是使用Avro完成的。

"key.converter.schemas.enable":"false",
"value.converter.schemas.enable":"false",

当Kafka Connect填充此主题时，它会在注册表中创建一个主题名为“主题名键”和“主题名值”的模式。例如，此模式可能具有如下配置的字段

"fields: [{"name" : "user_id", "type" : "long"}]

但当记录被拉入流媒体应用程序时，Kafka的代码（Kafka流：3.0.1）有一个模式伴随着数据。有时（并非总是）关联的模式具有不同的数据类型（user\u id是int而不是long）。

"fields: [{"name" : "user_id", "type" : "int"}]

抛出异常，并显示以下消息“正在注册的模式与主题的早期模式不兼容”。

问题：

1. 当schemas.enable=false时，为什么模式伴随Avro消息？
2. 为什么Kafka不使用关联的模式，而不是从模式注册表中查找它，比较注册表版本，并抱怨不兼容？

错误：

org.apache.kafka.streams.errors。StreamsException：进程中捕获到异常。taskId=0\u 1，processor=KSTREAM-SOURCE-0000000000，topic=member\u device\u 5，partition=1，offset=0，stacktrace=org.apache.kafka.common.errors。InvalidConfigurationException：正在注册的架构与主题“foo-campaign-KSTREAM-JOINOTHER-000000000 6-store-changelog-key”的早期架构不兼容；错误代码：409

Answer 1

为什么模式在运行模式时会伴随Avro消息。启用=false？

因为Avro总是有一个模式。它不能被禁用。该属性仅适用于JSONConverter（查看源代码）。

为什么Kafka不使用关联的模式而不是从模式注册表中查找它，

Kafka不在乎。您自己应用程序中的Serde在乎。如果您使用了特定的模式，您需要修改StreamsConfig属性映射以启用“specific.avro.reader”。否则，它将在反序列化期间使用注册表中的模式。

其次，foo-proxing-KSTREAM-JOINO-0000000006-store-change elog-key是注册表中自己的模式，与连接器写入Kafka的主题没有直接关系。

最重要的是，Avro long类型不能降级为int类型