如何解决使用JsonTreeReader在ConsumeKafkaRecord中设置schema.name
我正在尝试使用ConsumeKafkaRecord作为阅读器的JsonTreeReader处理器从Kafka进行读取。
我需要将schema.name的contoller服务器中的模式名称设置为AvroRegistry。
但是在从Kafka读取数据之前我该怎么做？
我还尝试将schema.name设置为静态值，甚至尝试将读取器中的schema.text属性（策略设置为读取schema.text）设置为原始模式json，它仍然错误地抱怨说它在流文件中找不到schema.name。
我如何将ConsumeKafkaRecord与JsonTreeReader一起使用？
解决方法
通常，如果您的读者使用“用户架构名称”，则“架构名称”默认为“ $ {schema.name}”，这意味着从传入流文件上的属性获取架构名称，该属性的名称为“ schema.name”。
由于ConsumerKafkaRecord（和所有其他使用Kafka的其他处理器）都是源处理器，因此没有带有属性的传入流文件，因此您不能引用$ {schema.name}。您必须在JsonTreeReader中将“架构名称”设置为实际的架构名称，而不是动态值。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
