Chapter 5. Using the Topic Operator

Procedure

1. Prepare a file containing the KafkaTopic to be created

   An example KafkaTopic

   apiVersion: kafka.strimzi.io/v1alpha1
   kind: KafkaTopic
   metadata:
     name: orders
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 10
     replicas: 2

   Copy to Clipboard Toggle word wrap

   Note

   It is recommended to use a topic name that is a valid OpenShift resource name. Doing this means that it is not necessary to set the KafkaTopic.spec.topicName property. In any case the KafkaTopic.spec.topicName cannot be changed after creation.

   Note

   The KafkaTopic.spec.partitions cannot be decreased.

2. Create the KafkaTopic resource in OpenShift.

   On OpenShift this can be done using oc apply:

   oc apply -f your-file

   Copy to Clipboard Toggle word wrap

Procedure

1. Prepare a file containing the desired KafkaTopic

   An example KafkaTopic

   apiVersion: kafka.strimzi.io/v1alpha1
   kind: KafkaTopic
   metadata:
     name: orders
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 16
     replicas: 2

   Copy to Clipboard Toggle word wrap

   Tip

   You can get the current version of the resource using oc get kafkatopic orders -o yaml.

   Note

   Changing topic names using the KafkaTopic.spec.topicName variable and decreasing partition size using the KafkaTopic.spec.partitions variable is not supported by Kafka.

   Important

   Increasing spec.partitions for topics with keys will change how records are partitioned, which can be particularly problematic when the topic uses semantic partitioning.

2. Update the KafkaTopic resource in OpenShift.

   On OpenShift this can be done using oc apply:

   oc apply -f your-file

   Copy to Clipboard Toggle word wrap

Procedure

1. Delete the KafkaTopic resource in OpenShift.

   On OpenShift this can be done using oc:

   oc delete kafkatopic your-topic-name

   Copy to Clipboard Toggle word wrap
   Note

   Whether the topic can actually be deleted depends on the value of the delete.topic.enable Kafka broker configuration, specified in the Kafka.spec.kafka.config property.