Update values for demo01-kaf-conn-sink2

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.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
+    tarnsforms.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 
+
+
+
+