我可以从org.apache.kafka.clients.consumer.consumerrecord禁用架构验证吗? 我有一项工作,可以从kafka获取消费者,并使用avroparquetwriter写入镶木quet文件。现在,我想在镶木木中添加一个字段,但要低于错误: org.apache.avro.

问题描述 投票:0回答:1

奇怪的是,我可以禁用验证吗?

应该能够通过set enable.schema.validation = false完成。但是我实际上需要的是通过添加一个字段

通过Java API扩展Avro架构

apache-kafka apache-nifi
1个回答
0
投票
最新问题
© www.soinside.com 2019 - 2025. All rights reserved.