Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Kafka triggered function [Java] not deserializing Avro with an array structure #452

Open
krishna-kariya opened this issue Aug 9, 2023 · 0 comments

Comments

@krishna-kariya
Copy link
Contributor

While using Kafka triggered function with Avro schema, if the Avro schema has an array structure, then Kafka event message is not mapped with schema fields correctly and array field are set as null.
Example Schema -

{
  "type": "record",
  "name": "pageviews",
  "namespace": "ksql",
  "fields": [
    {
      "name": "viewtime",
      "type": "long"
    },
    {
      "name": "pages",
        "type": {
            "type": "array",
            "items": {
            "type": "record",
            "name": "nestedPage",
            "fields": [
                {
                "name": "name",
                "type": "int"
                }
            ]
            }
        }   
    }
  ]
}

With above schema, the trigger processes the message with nestedPage as null. This looks like an issue related to Avro Deserialization.

Ref - https://portal.microsofticm.com/imp/v3/incidents/details/405766769/home

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant