5.2.3. 配置 Kafka 主题
使用 KafkaTopic
资源的属性来配置 Kafka 主题。
您可以使用 oc apply
创建或修改主题,使用 oc delete
删除现有主题。
例如:
-
oc apply -f <topic-config-file>
-
oc delete KafkaTopic <topic-name>
此流程演示了如何创建带有 10 个分区和 2 个副本的主题。
开始前
在进行更改前请考虑以下几点:
Kafka 不支持 通过
KafkaTopic
资源进行以下更改:-
使用
spec.topicName
更改主题名称 -
使用
spec.partitions
减少分区大小
-
使用
-
您不能使用
spec.replicas
来更改最初指定的副本数量。 -
使用键为主题增加
spec.partitions
将更改记录的分区方式,这在主题使用 语义分区 时特别有问题。
先决条件
- 正在运行的 Kafka 集群使用 Kafka 代理监听程序配置使用 TLS 身份验证和加密。
- 一个正在运行的主题 Operator( 通常使用 Entity Operator 部署)。
-
要删除主题,请在
Kafka
资源的spec.kafka.config 中
(default)。delete.topic.
enable=true
流程
准备包含要创建的
KafkaTopic
的文件。KafkaTopic 示例
apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaTopic metadata: name: orders labels: strimzi.io/cluster: my-cluster spec: partitions: 10 replicas: 2
提示在修改主题时,您可以使用
oc get kafkatopic Order -o yaml 获取资源的当前版本
。在 OpenShift 中创建
KafkaTopic
资源。oc apply -f TOPIC-CONFIG-FILE