[ 
https://issues.apache.org/jira/browse/NIFI-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229094#comment-17229094
 ] 

Alasdair Brown edited comment on NIFI-7376 at 11/10/20, 9:53 AM:
-----------------------------------------------------------------

FYI see NIFI-7917 which is tracking Avro upgrade to 1.10


was (Author: sdairs):
FYI see NIFI-7917

> Avro Single-object encoding Support
> -----------------------------------
>
>                 Key: NIFI-7376
>                 URL: https://issues.apache.org/jira/browse/NIFI-7376
>             Project: Apache NiFi
>          Issue Type: Improvement
>          Components: Core Framework
>    Affects Versions: 1.9.2
>            Reporter: Nathan English
>            Priority: Minor
>
> For my Flows I consume Avro Binary Encoded Messages from Kafka which is 
> currently working great! However going forward one of our inputs is looking 
> to provide [Avro Single-object 
> Encoding|[https://avro.apache.org/docs/1.8.2/spec.html#single_object_encoding]].
>  
> Avro Single Object Encoding provides us a way to where we don't have to have 
> the overhead and message size increase of embedding the schema in the 
> message. Single Object Encoding achieves this with a couple of extra fields 
> to firstly confirm the message is an Avro message and secondly a fingerprint 
> of the schema used to encode the message.
> This is a massive benefit for us, because we have multiple of the same device 
> producing messages into one Kafka Topic. This is fine until we start 
> upgrading these devices where schema changes may occur, this is when schema 
> fingerprinting comes into its element.
> From all the information I have found, it looks to me as if Avro Single 
> Object Encoding was added in version 1.8.2 of the Avro Specification. NiFi is 
> currently using version 1.8.1 of the Avro Specification based on the 
> [pom|[https://github.com/apache/nifi/blob/rel/nifi-1.11.4/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml]]
>  in NiFi Record Serialization Services section of the github project.
> I'm sure there are a million ways to tackle this issue and I'm personally 
> haven't done enough research on NiFi or Avro on it to suggest a way to 
> resolve this, but I can tell it's not as simple as just upgrading the Avro 
> version used.
> My thoughts were to upgrade the Library version, then modify the avro schema 
> registry to either take in a fingerprint value or have it calculated on 
> enablement of the registry. I'm sure it's probably not as simple as I have 
> just made it!.
> More than happy to help where I can.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to