[I] [Feature] kafka cdc support metadata_column [paimon]

["melin (via GitHub)" <gi...@apache.org>]

melin opened a new issue, #3210:
URL: https://github.com/apache/paimon/issues/3210

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar.
   
   
   ### Motivation
   
   Get metadata from kafka header, such as database, tablename, and other keys/values
   
   flink cdc kafka pipeline writes database, tablename to kafka header, plan to support custom key/value
   https://github.com/apache/flink-cdc/pull/2938
   
   ### Solution
   
   _No response_
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


-- 
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: issues-unsubscribe@paimon.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Feature] kafka cdc support metadata_column [paimon]

["melin (via GitHub)" <gi...@apache.org>]

melin commented on issue #3210:
URL: https://github.com/apache/paimon/issues/3210#issuecomment-2055554898

   cc @zhuangchong 


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org