You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "sivabalan narayanan (Jira)" <ji...@apache.org> on 2023/11/30 15:25:00 UTC

[jira] [Closed] (HUDI-7108) Ensure schema is refreshed for every batch when using KafkaAvroSchemaDeserializer

     [ https://issues.apache.org/jira/browse/HUDI-7108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

sivabalan narayanan closed HUDI-7108.
-------------------------------------
    Fix Version/s: 0.14.1
         Assignee: Rajesh Mahindra
       Resolution: Fixed

> Ensure schema is refreshed for every batch when using KafkaAvroSchemaDeserializer
> ---------------------------------------------------------------------------------
>
>                 Key: HUDI-7108
>                 URL: https://issues.apache.org/jira/browse/HUDI-7108
>             Project: Apache Hudi
>          Issue Type: Bug
>            Reporter: Rajesh Mahindra
>            Assignee: Rajesh Mahindra
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 0.14.1
>
>
> In Kafka AVRO source, the schema config for KafkaAvroSchemaDeserializer is only set during constructor and not refreshed for every batch. In Deltastreamer cont. mode, this creates an issue when schema evolves for the kafka messages.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)