parent
0d141e68af
commit
f74a543f90
@ -0,0 +1,35 @@ |
|||||||
|
#version: kafka-connector, 1.0.0 |
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
--- |
||||||
|
apiVersion: kafka.strimzi.io/v1beta2 |
||||||
|
kind: KafkaConnector |
||||||
|
metadata: |
||||||
|
name: "demo01-kaf-kong-sink4-kafka-starrocks" |
||||||
|
namespace: kafka-cluster |
||||||
|
labels: |
||||||
|
strimzi.io/cluster: kafka-cluster |
||||||
|
spec: |
||||||
|
class: com.starrocks.connector.kafka.StarRocksSinkConnector |
||||||
|
tasksMax: 6 |
||||||
|
config: |
||||||
|
topics: "demo01.logging.kong" |
||||||
|
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.logging.kong:kong_log_events" |
||||||
|
key.converter: "org.apache.kafka.connect.json.JsonConverter" |
||||||
|
value.converter: "org.apache.kafka.connect.json.JsonConverter" |
||||||
|
key.converter.schemas.enable: "true" |
||||||
|
value.converter.schemas.enable: "false" |
||||||
|
|
||||||
Loading…
Reference in new issue