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 : https://github.com/apache/hudi/blob/master/hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/KafkaOffsetPostProcessor.java#L54 Similarly to above, i would like to add kafka key as well & same can be implemented for other kafka sources as well. Once you confirm, i can raise the PR for the same. Thanks & awaiting your confirmation. -- 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]
