rmahindra123 opened a new pull request #4063: URL: https://github.com/apache/hudi/pull/4063
## What is the purpose of the pull request Add Debezium Source for deltastreamer, allowing deltastreamer users to ingest the debezium change log records from kafka for Postgres DB. ## Brief change log - Implemented a debezium source that can ingest JSON and AVRO change records from debezium kafka connector. The schema is read from the confluent schema registry - Implemented a debezium payload that implement preCombine and merge of records based on the LSN field in postgres, that represents the actual sequence of the change logs - ## Verify this pull request Tested with RDS instance of postgres, debezium kafka connect and kafka. Tested with insert, update and delete operations. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
