emqx in k8s with kafka config example

emqx-enterprise.yaml

apiVersion: apps.emqx.io/v2beta1
kind: EMQX
metadata:
  name: emqx
spec:
  image: emqx/emqx-enterprise:5.6.0
  config:
    data: |
      log.console.level = debug
      connectors {
        kafka_producer {
          cloud {
            authentication {
              mechanism = plain
              username = kafka_username
              password = "file:///mounted/kafka/password.txt"
            }
            bootstrap_hosts = "localhost:9092"
            ssl {enable = true, verify = verify_peer}
          }
        }
      }
      actions {
        kafka_producer {
          cloud {
            connector = cloud
            enable = true
            parameters {
              message {
                key = "${.clientid}"
                timestamp = "${.timestamp}"
                value = "${.}"
              }
              topic = "emqx"
            }
          }
        }
      }

  coreTemplate:
    spec:
      replicas: 3
      extraVolumes:
        - name: kafka-creds
          secret:
            secretName: kafka-creds
      extraVolumeMounts:
        - name: kafka-creds
          mountPath: /mounted/kafka
  dashboardServiceTemplate:
    enabled: true
    spec:
      type: LoadBalancer

secret.yaml

apiVersion: v1
kind: Secret
metadata:
  name: kafka-creds
type: Opaque
stringData:
  password.txt: |
    password123