You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
36 lines
1.2 KiB
36 lines
1.2 KiB
#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
|
|
transform.unwrap.type: io.debezium.transforms.ExtractNewRecordState
|
|
transform.unwarp.drop.tombstones: true
|
|
transforms.unwarp.delete.handling.mode: rewrite
|
|
|
|
|
|
|
|
|
|
|