Using a Kafka service
The YAML code below creates two objects: a
ExoscaleKafka instance and a Pod accessing it to show information about the instance.
The latter references the
kafka-creds secret that will contain the access keys required to connect to the instance.
|We provide a sample container that supports client side certificates and should work out of the box. It will create a test topic and will continuously publish to and read from that topic. Aiven has example code in multiple languages that may help you to get started with your own application.|
apiVersion: exoscale.appcat.vshn.io/v1 kind: ExoscaleKafka metadata: name: my-kafka-example namespace: my-namespace spec: parameters: service: zone: ch-dk-2 writeConnectionSecretToRef: name: kafka-creds (1) --- apiVersion: v1 kind: Pod metadata: name: kafka-client namespace: my-namespace spec: containers: - name: client image: ghcr.io/vshn/appcat-kafka-example:v1.0.0 args: - --ca - /.kafka/certs/ca.crt - --cert - /.kafka/certs/service.cert - --key - /.kafka/certs/service.key envFrom: - secretRef: name: kafka-creds (2) volumeMounts: - name: certs mountPath: /.kafka/certs volumes: - name: certs secret: secretName: kafka-creds (2)
|1||The operator will create a secret with the access keys to connect to the instance.|
|2||The pod and its volume will use the secret.|