update

Former-commit-id: a0201ac53fad44ec500068950ea68936b7507993
Former-commit-id: f737db8c600c642742c05f8ed944b4c5a86c87c2

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"
     }