Kafka JDBC Sink ConnectorKafka JDBC接收器连接器提供了3个插入模式,但我需要更新或插入功能在一起。任何人都可以帮助如何实现这一点。
pcww981p1#
upsert字面意思是插入或更新已插入的现有键
upsert
hxzsmxv22#
您可以考虑以下步骤:1.源连接器上两个主题之间的分离事件(插入主题和更新主题)1.处理具有不同配置的独立宿连接器的三个主题。
2条答案
按热度按时间pcww981p1#
upsert
字面意思是插入或更新已插入的现有键hxzsmxv22#
您可以考虑以下步骤:
1.源连接器上两个主题之间的分离事件(插入主题和更新主题)
1.处理具有不同配置的独立宿连接器的三个主题。