From 7f50141f72faf62faa5588b4efad567ff48399d4 Mon Sep 17 00:00:00 2001 From: system Date: Tue, 11 Nov 2025 03:14:58 +0000 Subject: [PATCH] Update values for demo01-kaf-conn-sink2 --- demo01-kaf-conn-sink2/values.yaml | 33 +++++++++++++++++++++++++++++++ 1 file changed, 33 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..e929663 --- /dev/null +++ b/demo01-kaf-conn-sink2/values.yaml @@ -0,0 +1,33 @@ +#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.StarRocksSingConnector + tasksMax: 6 + config: + topics: "prometheus.metric" + starrocks.http.url: kube-starrocks-fe-service.demo01.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: "prometheus.metric:prom_metric" + transforms: addfield,unwrap + tarnsforms.addfield.type: com.starrocks.connector.kafka.transforms.AddOpFieldForkDebeziumRecord + transform.unwrap.type: io.debezium.transforms.ExtractNewRecordState + transform.unwarp.drop.tombstones: true + transforms.unwarp.delete.handling.mode: rewrite +