[FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name.#3805

Merged

leonardBang merged 3 commits intoapache:masterfrom

lvyanquan:FLINK-36913

Jan 16, 2025

Commits on Jan 16, 2025

[FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name.
lvyanquan
committed
Address comments.
lvyanquan
committed
Address comments.
lvyanquan
committed