parent
ffae58736e
commit
c354ae3da7
@ -0,0 +1,35 @@ |
||||
#version: kafka-connector, 1.0.0 |
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
--- |
||||
apiVersion: kafka.strimzi.io/v1beta2 |
||||
kind: KafkaConnector |
||||
metadata: |
||||
name: "demo01-kaf-log-sink-kafka-starrocks" |
||||
namespace: kafka-cluster |
||||
labels: |
||||
strimzi.io/cluster: kafka-cluster |
||||
spec: |
||||
class: com.starrocks.connector.kafka.StarRocksSinkConnector |
||||
tasksMax: 6 |
||||
config: |
||||
topics: "demo01.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