paimon icon indicating copy to clipboard operation
paimon copied to clipboard
verified publisher icon apache

[Feature] kafka cdc support metadata_column

Open melin opened this issue 1 year ago • 1 comments

Search before asking

  • [X] I searched in the 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!

melin avatar Apr 15 '24 06:04 melin

cc @zhuangchong

melin avatar Apr 15 '24 06:04 melin