在Apache Nifi中配置csvReader以使用Avro模式注册表时遇到错误
csvReader属性集：在此处输入图像描述
这是我在AvroSchema注册表中创建和注册的架构
{ "namespace": "nifi "，" type": "record "，" name": "users "，" fields" : [ {"name": "first_name "，" type": "string"}，{"name": "last_name "，" type": "string"}，{"name": "age "，" type": "int"} ] }
我在运行Apache-nifi处理器时遇到的错误
org.apache.nifi.schema.access.SchemaNotFoundException：FlowFile不包含适当的属性来确定Schema Text
共有1个答案
将您的CSVReader配置为-
< code >架构访问策略 = 使用“架构名称”属性
Schema注册表=您的AvroSchemaRegistry控制器服务
架构名称=用户
模式文本=让它成为默认值
这意味着CSVReader将在schema registry中搜索指定的模式名，因为访问策略是模式名，我们将其传递给注册表。
-
我正在尝试使用Confluent schema registry，下面是我在Github中找到的一些示例(https://github.com/gAmUssA/springboot-kafka-avro). 当消费者和生产者与模型共享相同的命名空间而不是其工作时。 当使用者位于具有不同名称空间但具有相同类（名称和属性方面）的不同项目中时，它不工作。 合流Avro反序列化程序可以使用正确的值反序列化
-
如果不是--如何修复？
-
我有一个Kafka消费者配置了主题中的模式轮询，我想做的是在当前模式的基础上创建另一个Avro模式，并使用它水合数据，基本上我不需要50%的信息，需要编写一些逻辑来更改几个字段。这只是一个例子 从stream返回的事件相当复杂，所以我将一个较小的CustomObj建模为. avsc文件，并将其编译成java。当尝试使用CustomObj运行代码时，我想做的就是使用一个事件，然后将其反序列化为一个更
-
我正在处理一些注册过程的Android应用程序（原生Android），使用AWS放大和Cognito用户池从这个链接https://aws-amplify.github.io/docs/android/authentication#signup。 我已经做了，直到放大添加验证和放大推送。我的原始文件夹中有配置文件。在实现注册功能后，我在尝试从我的应用程序注册时遇到以下错误： 2019-10-23
-
我正在Windows7主机上运行Hortonworks 2.2沙盒。我已经为虚拟机分配了2GB内存。每次尝试创建表时，都会出现以下错误： HCatClient在创建表时出错：{“语句”：“使用默认值；创建表kjdrg（bigint，bigint，bigint）注释“k”行格式分隔字段，以“，”；”终止，错误）：“无法创建表：kjdrg”，“exec:{“stdout”：“stderr”："15/0
-
我已经设置了Spring Cloud Stream中提供的Spring Avro模式注册表，以便在RabbitMQ中使用。我看到的大多数示例都使用Maven Avro插件从模式资源文件生成Java类。然后在架构注册表中注册架构文件。我的理解是，此注册表允许消息仅通过对已注册架构的引用进行SERDE，而不是在消息中包含整个架构。我不明白的是，在设计时，这些模式文件是如何在所有服务之间分发的，以生成J