Confluent Elasticsearch Sink 连接器，write.method：不同键上的“UPSERT”答案

【问题标题】：Confluent Elasticsearch Sink connector, write.method : "UPSERT" on different keyConfluent Elasticsearch Sink 连接器，write.method：不同键上的“UPSERT”
【发布时间】：2021-04-07 03:39:50
【问题描述】：

在 COnfluent Elasticsearch Sink 连接器中，我试图从两个不同的主题写入相同的 Elasticsearch 索引。第一个主题是 INSERT，另一个主题是 UPSERT。对于 UPSERT，我想根据其他字段而不是“_id”来更新 JSON 文档。那可能吗？如果是，我该怎么做？

【问题讨论】：

标签： elasticsearch kafka-consumer-api apache-kafka-connect confluent-platform upsert

【解决方案1】：

使用 key.ignore=false 并使用现有的主键列作为每个 json 文档的 _id。

【讨论】：