实现源和目标之间的实时同步
GetKafka处理器用于从源Kafka主题中获取消息，而PutKafka处理器用于将消息写入目标Kafka主题。可以将这两个处理器连接起来以创建一个数据流管道，从而实现源和目标之间的实时同步。
利用UpdateAttribute 实现json，avro，csv类型内容的传输
UpdateAttribute是Apache NiFi中的一个处理器，可以用于修改FlowFile的属性。要利用UpdateAttribute实现json、avro和csv类型内容的传输，可以按照以下步骤进行配置：
1. 首先，将json、avro或csv数据写入FlowFile的内容中。可以使用GetFile、GetHTTP等处理器从文件或网络中获取数据，并将其写入FlowFile的内容中。
2. 接下来，在UpdateAttribute处理器中添加一个新属性，例如“Content-Type”，并将其值设置为相应数据类型的MIME类型。例如，对于json数据，可以将“Content-Type”设置为“application/json”，对于avro数据，可以将其设置为“application/avro-binary”，对于csv数据，则可以将其设置为“text/csv”。
3. 最后，在NiFi流程中添加适当的处理器来读取和处理这些不同类型的数据。例如，对于json数据，可以使用EvaluateJsonPath、SplitJson等处理器来解析和拆分JSON对象；对于avro数据，则需要使用ConvertAvroToJSON、ConvertRecord等处理器来转换和解析Avro格式；对于csv数据，则需要使用SplitText、ConvertRecord等处理器来拆分和转换CSV格式。
通过这种方式，就可以在NiFi流程中实现不同类型数据的传输和处理。
