Accessing topics from an application¶

This guide shows you how to access Kafka topics from your application.

Prerequisites¶

You need an existing topic to access. See Create a Kafka topic for how to create a topic.

Enable access to the relevant pool in your workload definition¶

  apiVersion: nais.io/v1alpha1
  kind: Application
  metadata:
    name: <MY-APP>
    namespace: <MY-TEAM>
    labels:
      team: <MY-TEAM>
  spec:
    kafka:
      pool: <MY-POOL>

Select a pool from one of the available pools.

Grant access to the topic¶

The owner of the topic must grant your application access to the topic.

Configure your application¶

Aiven has written several articles on how to configure your application. We use SSL, so ignore the SASL-SSL examples:

• Java
• Python
• Node.js
• Go

For all available environment variables, see the reference.

We recommend following the application design guidelines for how to configure your application.

Apply the application¶

kubectl apply -f ./nais/app.yaml --namespace=<MY-TEAM> --context=<MY-CLUSTER>