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 中 delete.topic. enable=true (default)。

流程

准备包含要创建的 KafkaTopic 的文件。

KafkaTopic 示例

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

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

Copy to Clipboard

Toggle word wrap

提示

在修改主题时，您可以使用 oc get kafkatopic Order -o yaml 获取资源的当前版本。

在 OpenShift 中创建 KafkaTopic 资源。
```
oc apply -f TOPIC-CONFIG-FILE
```
```
oc apply -f TOPIC-CONFIG-FILE
```
Copy to Clipboard Toggle word wrap

返回顶部

5.2.3. 配置 Kafka 主题

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links