我需要Kafka JDBC接收连接器中的更新或插入功能

wtlkbnrh  于 2022-12-11  发布在  Apache
关注(0)|答案(2)|浏览(119)

Kafka JDBC Sink Connector
Kafka JDBC接收器连接器提供了3个插入模式,但我需要更新或插入功能在一起。任何人都可以帮助如何实现这一点。

pcww981p

pcww981p1#

upsert字面意思是插入或更新已插入的现有键

hxzsmxv2

hxzsmxv22#

您可以考虑以下步骤:
1.源连接器上两个主题之间的分离事件(插入主题和更新主题)
1.处理具有不同配置的独立宿连接器的三个主题。

相关问题