Managed Service for Apache Kafka®

Managed Service for Apache Kafka® is a message broker that allows you to implement an architecture using message queues. Using this component, you can create clusters and topics and manage user access by leveraging the following custom resources:

• KafkaCluster: To create a cluster.
• KafkaTopic: To work with topics.
• KafkaUserAccess: To manage user access.

You can manage integration with Apache Kafka® using the ManagedKafkaConfig custom resource settings.

ConfigurationConfiguration

Here is an example:

apiVersion: stackland.yandex.cloud/v1alpha1
kind: ManagedKafkaConfig
metadata:
  name: main
spec:
  enabled: true
  settings:
    defaultStorageClass: stackland-default
    stackland-kafka:
      replicas: 1
      resources:
        limits:
          cpu: "500m"
          memory: "512Mi"
        requests:
          cpu: "200m"
          memory: "256Mi"
    strimzi-kafka:
      replicas: 1
      resources:
        limits:
          cpu: "500m"
          memory: "512Mi"
        requests:
          cpu: "100m"
          memory: "256Mi"
    monitoring:
      enabled: false

Where:

• defaultStorageClass: Sets the default storage class for Apache Kafka® topics.
• stackland-kafka: Stackland Kafka operator settings, such as replicas standing for the replica count and resources specifying CPU and memory limits.
• strimzi-kafka: Strimzi Kafka operator settings, such as replicas and resources (when using Strimzi).
• defaultKafkaResources, defaultControllerResources: Default resources for Kafka brokers and the controller. These settings are optional.
• monitoring.enabled: Specifies whether to enable component monitoring. This is an optional setting.