0

有谁知道如何在 SinkConnector 连接器中传递动态参数而不是传递静态值(下面的示例):

"transforms.InsertSourceDetails.static.field":"messagesource",
"transforms.InsertSourceDetails.static.value":"Debezium CDC from MySQL on asgard"

我正在寻找如何传递动态值,因为在我们的用例中使用 Debezium 是为了替换触发器,所以我们也需要替换它的规则。

先感谢您。

4

0 回答 0