Strimzi · Example Payload

Strimzi Kafka Cluster Example

Example Kafka cluster resource for a 3-broker production cluster with persistent storage and TLS

KafkaKubernetesMessagingOperatorStreaming

Strimzi Kafka Cluster Example is an example object payload from Strimzi, with 3 top-level fields. It illustrates the shape of data this provider's APIs accept or return.

Top-level fields

descriptionmanifestexpectedStatus

Example Payload

{
  "description": "Example Kafka cluster resource for a 3-broker production cluster with persistent storage and TLS",
  "manifest": {
    "apiVersion": "kafka.strimzi.io/v1beta2",
    "kind": "Kafka",
    "metadata": {
      "name": "my-cluster",
      "namespace": "kafka"
    },
    "spec": {
      "kafka": {
        "replicas": 3,
        "version": "3.7.0",
        "storage": {
          "type": "persistent-claim",
          "size": "100Gi",
          "class": "gp3"
        },
        "listeners": [
          {
            "name": "plain",
            "port": 9092,
            "type": "internal",
            "tls": false
          },
          {
            "name": "tls",
            "port": 9093,
            "type": "internal",
            "tls": true
          }
        ],
        "config": {
          "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",
          "log.retention.hours": "168"
        },
        "resources": {
          "requests": {
            "cpu": "1",
            "memory": "2Gi"
          },
          "limits": {
            "cpu": "2",
            "memory": "4Gi"
          }
        }
      },
      "zookeeper": {
        "replicas": 3,
        "storage": {
          "type": "persistent-claim",
          "size": "20Gi",
          "class": "gp3"
        }
      },
      "entityOperator": {
        "topicOperator": {},
        "userOperator": {}
      }
    }
  },
  "expectedStatus": {
    "conditions": [
      {
        "type": "Ready",
        "status": "True",
        "message": "Kafka cluster my-cluster is ready"
      }
    ],
    "listeners": [
      {
        "name": "plain",
        "bootstrapServers": "my-cluster-kafka-bootstrap.kafka.svc.cluster.local:9092",
        "type": "internal"
      },
      {
        "name": "tls",
        "bootstrapServers": "my-cluster-kafka-bootstrap.kafka.svc.cluster.local:9093",
        "type": "internal"
      }
    ]
  }
}