parent
fa27f2db36
commit
1a7cefc14a
@ -1,36 +0,0 @@ |
||||
#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 |
||||
|
||||
|
||||
|
||||
|
||||
Loading…
Reference in new issue