5.2.2. 配置 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 将更改记录的分区方式,这在主题使用 语义分区 时特别有问题。

先决条件

步骤

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

    KafkaTopic 示例

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

    提示

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

  2. 在 OpenShift 中创建 KafkaTopic 资源。

    oc apply -f TOPIC-CONFIG-FILE
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.