Создать кластер Apache Kafka®

1. Если проект еще не создан, то создайте его: kubectl create namespace <название проекта>.

2. Создайте файл ресурса KafkaCluster. Например, с помощью команды touch kafkacluster.yaml.

3. Откройте файл и вставьте конфигурацию ниже:

   apiVersion: kafka.stackland.yandex.cloud/v1alpha1
   kind: KafkaCluster
   metadata:
     name: cluster-omdb
     labels:
       environment: production
       tier: messaging
   spec:
     version: "4.0.0"
     controller:
       instances: 3
       storage:
         size: 1Gi
         # storageClass: "stackland-default"
     broker:
       instances: 3
       storage:
         size: 2Gi
         # storageClass: "stackland-default"
       diskAutoScaling:
         enabled: true
         maxSize: 300Gi
         minimalIncrement: 2Gi
         standardIncreasePercent: 20
         resizeTriggerPercent: 20
     listenerType: LoadBalancer # Network listener (LoadBalancer or ClusterIP)
     config: # configuration
       offsets.topic.replication.factor: 3
       transaction.state.log.replication.factor: 3
       transaction.state.log.min.isr: 2
       default.replication.factor: 3
       min.insync.replicas: 2
   

4. Примените манифест: kubectl apply -f kafkacluster.yaml -n <название проекта>. При необходимости можно прописать название проекта в параметр ресурса metadata.namespace и не использовать в команде.

Чтобы подключиться к кластеру, воспользуйтесь инструкцией Подключиться к кластеру Apache Kafka®.