1{
2  "_db_jobMeta": {
3    "name": "kafka_orders_to_iceberg_streaming",
4    "description": "Kafka topic_orders 消费后写入 Iceberg",
5    "parentFolderId": "folder_af42_bccdb16a1d00",
6    "type": "streaming",
7    "mode": "script"
8  },
9  "env": {
10    "job.mode": "STREAMING",
11    "parallelism": 1,
12    "_db_enableCheckpoint": false
13  },
14  "source": [
15    {
16      "plugin_name": "Kafka",
17      "_db_pluginId": "Kafka",
18      "plugin_output": "source_table",
19      "_db_connectionId": "kafka-conn-001",
20      "_db_syncMode": "INCREMENT",
21      "_db_startingOffset": "latest",
22      "_db_startTimestamp": "2026-01-01 00:00:00"
23    }
24  ],
25  "sink": [
26    {
27      "plugin_name": "Iceberg",
28      "_db_pluginId": "Iceberg-streaming",
29      "plugin_input": "source_table",
30      "_db_sinkPath": "lake.default",
31      "_db_catalog": "lake",
32      "_db_schema": "default",
33      "_db_sinkTableType": "MANAGED"
34    }
35  ],
36  "_db_tableConfigs": [
37    {
38      "tableIdentity": {
39        "sourceTable": "topic_orders",
40        "sinkTable": "ods_orders"
41      },
42      "source": {
43        "format": "json",
44        "_inter_jsonSample": "{\"id\":1,\"name\":\"demo\",\"amount\":100.0}"
45      },
46      "mapping": {
47        "sourceFields": [
48          {
49            "name": "id",
50            "type": "BIGINT"
51          },
52          {
53            "name": "name",
54            "type": "STRING"
55          },
56          {
57            "name": "amount",
58            "type": "DOUBLE"
59          }
60        ]
61      },
62      "sink": {
63        "_db_isAutoCreated": true,
64        "_db_sinkNameRule": "SAME",
65        "_db_dmlConfig": {
66          "insert": "INSERT",
67          "update": "UPDATE",
68          "delete": "DELETE",
69          "logicalDeleteTag": ""
70        }
71      }
72    }
73  ]
74}