Кто-нибудь знает, как передать динамический параметр в соединитель SinkConnector вместо передачи статического значения (пример ниже):
"transforms.InsertSourceDetails.static.field":"messagesource",
"transforms.InsertSourceDetails.static.value":"Debezium CDC from MySQL on asgard"
Я ищу, как передать динамическое значение, как использованиеDebezium в нашем сценарии использования состоит в замене триггера, поэтому нам нужно заменить и его правила.
Заранее спасибо.