From 1746b93b1143388ffebd41d548914525b0c7104c Mon Sep 17 00:00:00 2001 From: system Date: Wed, 12 Nov 2025 04:49:40 +0000 Subject: [PATCH] Update values for demo01-kaf-conn-sink2 --- demo01-kaf-conn-sink2/values.yaml | 36 +++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 demo01-kaf-conn-sink2/values.yaml diff --git a/demo01-kaf-conn-sink2/values.yaml b/demo01-kaf-conn-sink2/values.yaml new file mode 100644 index 0000000..ed49d4e --- /dev/null +++ b/demo01-kaf-conn-sink2/values.yaml @@ -0,0 +1,36 @@ +#version: kafka-connector, 1.0.0 + + + + + + +--- +apiVersion: kafka.strimzi.io/v1beta2 +kind: KafkaConnector +metadata: + name: "demo01-kaf-conn-sink2-kafka-starrocks" + namespace: kafka-cluster + labels: + strimzi.io/cluster: kafka-cluster +spec: + class: com.starrocks.connector.kafka.StarRocksSinkConnector + tasksMax: 6 + config: + topics: "demo01.public.subway_info_copy, demo01.public.subway_passengers_copy, demo01.public.subway_passengers_time_copy" + starrocks.http.url: kube-starrocks-fe-service.demo01-star3.svc.cluster.local:8030 + starrocks.database.name: "quickstart" + starrocks.username: "root" + starrocks.password: "sdHwyKH8p6Xw" + sink.properties.strip_outer_array: true + connect.timeoutms: "30000" + starrocks.topic2table.map: "demo01.public.subway_info_copy:subway_info_copy, demo01.public.subway_passengers_copy:subway_passengers_copy, demo01.public.subway_passengers_time_copy:subway_passengers_time_copy" + transforms: addfield,unwrap + transforms.addfield.type: com.starrocks.connector.kafka.transforms.AddOpFieldForDebeziumRecord + transforms.unwrap.type: io.debezium.transforms.ExtractNewRecordState + transforms.unwarp.drop.tombstones: true + transforms.unwarp.delete.handling.mode: rewrite + + + +