Sam-Serpoosh commented on issue #8519: URL: https://github.com/apache/hudi/issues/8519#issuecomment-1546481863
@the-other-tim-brown According to this [SO question/thread](https://stackoverflow.com/questions/76239689/non-nested-avro-schema-for-postgres-change-log-events-debezium-confluent-sch), it seems like **nesting** under the `Value` object in Avro (de)serialization is a **normal** behavior. Then I'm surprised that others haven't seen an issue with this when it comes to `Debezium <> Hudi`. Unless my hypothesis is inaccurate and Hudi is actually capable of gracefully handling incoming Kafka messages with a **nested Value** object in them?! In the meantime, I'm going to work on a simple patch which would change this line (same with its counterpart on BEFORE): https://github.com/apache/hudi/blob/622d27a099f5dec96f992fd423b666083da4b24a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/debezium/PostgresDebeziumSource.java#L64 To this (same with its counterpart on BEFORE): ```java String.format("%s.Value.*", DebeziumConstants.INCOMING_AFTER_FIELD) ``` And see IF that'll resolve the issue or not?! -- 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]
