broker.yaml

# Copyright 2023 The Knative Authors
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
  name: {{ .name }}
  namespace: {{ .namespace }}
  {{ if or .brokerClass .annotations }}
  annotations:
  {{ if .brokerClass }}
    eventing.knative.dev/broker.class: {{ .brokerClass }}
  {{ end }}
  {{ if .annotations }}
    {{ range $key, $value := .annotations }}
    {{ $key }}: {{ $value }}
    {{ end }}
  {{ end }}
  {{ end }}
spec:
  {{ if .config }}
  config:
    kind: {{ .config.kind }}
    {{ if .configNamespace }}
    namespace: {{ .configNamespace }}
    {{ else }}
    namespace: {{ .namespace }}
    {{ end }}
    name: {{ .config.name }}
    apiVersion: {{ .config.apiVersion }}
  {{ else }}
  # if no config is given, use our default config
  config:
    kind: ConfigMap
    namespace: {{ .namespace }}
    name: kafka-broker-config
    apiVersion: v1
  {{ end }}
  {{ if .delivery }}
  delivery:
    {{ if .delivery.timeout }}
    timeout: {{ .delivery.timeout }}
    {{ end }}
    {{ if .delivery.deadLetterSink }}
    deadLetterSink:
      {{ if .delivery.deadLetterSink.ref }}
      ref:
        kind: {{ .delivery.deadLetterSink.ref.kind }}
        namespace: {{ .namespace }}
        name: {{ .delivery.deadLetterSink.ref.name }}
        apiVersion: {{ .delivery.deadLetterSink.ref.apiVersion }}
      {{ end }}
      {{ if .delivery.deadLetterSink.uri }}
      uri: {{ .delivery.deadLetterSink.uri }}
      {{ end }}
    {{ end }}
    {{ if .delivery.retry }}
    retry: {{ .delivery.retry}}
    {{ end }}
    {{ if .delivery.backoffPolicy }}
    backoffPolicy: {{ .delivery.backoffPolicy}}
    {{ end }}
    {{ if .delivery.backoffDelay }}
    backoffDelay: "{{ .delivery.backoffDelay}}"
    {{ end }}
  {{ end }}