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