ashishmgofficial opened a new issue #2149: URL: https://github.com/apache/hudi/issues/2149
Hi Team, Im facing this use case where I need to ingest data from kafka topic usinf Deltastreamer which is loaded using Debezium connector. So the topic contains schema which contains fields like `before, after, ts_ms, op, source` etc. Im providing record key as `after.id` and precombine key with `after.timestamp` but still the entire debezium output is being ingested. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
