我试图用Avro序列化程序和模式注册表向Kafka发送一个对象。 Properties props = new Properties(); ProducerRecord record = new ProducerRecord<>(topic, key, user);我假设模式是从注册表中支持的类型为空、布尔、整数、长、浮点、双、字符串、byte[
我已经创建了一个NiFi流,它最终将json记录发布为带有Avro编码值和字符串键的记录,使用模式中的模式。这是 in NiFi。我现在试图使用Kafka (connect-standalone)使用JdbcSinkConnector将消息移动到PostgreSQL数据库,但得到了以下错误:value.converter.schema.registr