Skip to content

Update to handle deletes in postgres debezium #15718

@hudi-bot

Description

@hudi-bot

We have onboarded our postgres tables to hudi via debezium and Kafka. It was running smooth until we have schema update and deletes coming into the topic. 

With schema update, we started seeing error mentioned in this issue

[https://github.com//issues/7219]

With deletes , we have run into the error where app failed with exceptions (I lost the stack trace for this). This PR handles both the errors in respective class. 

JIRA info

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions