#version: kafka-connector, 1.0.0









---
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: "demo01-kaf-log-sink2-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"
    errors.tolerance: "all"
    errors.deadletterqueue.topic.name: "demo01-kaf-log-sink2-dlq"
    errors.deadletterqueue.context.hearders.enable: "true"