diff --git a/demo01-kaf-conn-sink2/values.yaml b/demo01-kaf-conn-sink2/values.yaml new file mode 100644 index 0000000..8212dbc --- /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: "public.subway_info_copy, public.subway_passengers_copy, 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: "public.subway_info_copy:subway_info_copy, public.subway_passengers_copy:subway_passengers_copy, 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 + + + +