From 7ea9becc344fac9b58119b4c2110dd57efdae306 Mon Sep 17 00:00:00 2001
From: wanggang <76527413@qq.com>
Date: Fri, 30 Apr 2021 17:21:50 +0800
Subject: [PATCH] update

Former-commit-id: a0201ac53fad44ec500068950ea68936b7507993
Former-commit-id: f737db8c600c642742c05f8ed944b4c5a86c87c2
---
 labs/doris/conf/kafka-connect/kafka2elasticsearch.json | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/labs/doris/conf/kafka-connect/kafka2elasticsearch.json b/labs/doris/conf/kafka-connect/kafka2elasticsearch.json
index cf4fd686..744757d6 100644
--- a/labs/doris/conf/kafka-connect/kafka2elasticsearch.json
+++ b/labs/doris/conf/kafka-connect/kafka2elasticsearch.json
@@ -4,16 +4,14 @@
         "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
         "tasks.max": 1,
         "topics": "mysql.example.User",
-        "key.ignore": false,
+        "key.ignore": true,
         "key.converter.schemas.enable": false,
         "key.converter": "org.apache.kafka.connect.storage.StringConverter",
         "connection.url": "http://elasticsearch:9200",
         "type.name": "kafka-connect",
         "write.method": "upsert",
         "behavior.on.null.values": "delete",
-        "transforms": "key,ExtractFieldObject",
-        "transforms.key.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
-        "transforms.key.field": "Id",
+        "transforms": "ExtractFieldObject",
         "transforms.ExtractFieldObject.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
         "transforms.ExtractFieldObject.field": "after"
     }