parent
cbcce5a375
commit
37e831655d
@ -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