[GitHub] [hudi] prathit06 commented on issue #9391: [ENHANCEMENT] Kafka Key as part of hudi metadata columns

2023-08-08 Thread via GitHub
prathit06 commented on issue #9391: URL: https://github.com/apache/hudi/issues/9391#issuecomment-1670575984 Hi guys, I have created this PR : https://github.com/apache/hudi/pull/9403 for the changes. Request to please review it & let me know if any changes needed. Thanks a lot ! -

[GitHub] [hudi] prathit06 commented on issue #9391: [ENHANCEMENT] Kafka Key as part of hudi metadata columns

2023-08-08 Thread via GitHub
prathit06 commented on issue #9391: URL: https://github.com/apache/hudi/issues/9391#issuecomment-1669955523 Hi @vinothchandar My idea is to `extend the Hudi metadata columns` itself similar to what is done [here](https://github.com/apache/hudi/blob/master/hudi-utilities/src/main/jav

[GitHub] [hudi] prathit06 commented on issue #9391: [ENHANCEMENT] Kafka Key as part of hudi metadata columns

2023-08-08 Thread via GitHub
prathit06 commented on issue #9391: URL: https://github.com/apache/hudi/issues/9391#issuecomment-1669207704 @danny0405 thanks for checking this. Just to add, for Kafka source , metadata such as offset, timestamp & partition already exists, but kafka key is missing. Refer : htt