Skip to main content
 首页 » 编程设计

apache-kafka之如何在Apache Kafka中创建主题

2025年02月15日17lidabo

在Kafka中创建主题的最佳方法是什么?

  • 创建主题时要定义多少个副本/分区?

  • 在新的生产者API中,当我尝试将消息发布到不存在的主题时,它第一次失败,然后成功发布。
  • 我想知道副本,分区和集群节点数量之间的关系。
  • 我们需要在发布消息之前创建主题吗?
  • 请您参考如下方法:

    启动Kafka代理时,可以在conf/server.properties文件中定义属性集。该文件只是键值属性文件。属性之一是auto.create.topics.enable,如果将其设置为true(默认情况下),则当您将消息发送到不存在的主题时,Kafka将自动创建主题。

    您可以找到的所有配置选项均已定义here。恕我直言,创建主题的简单规则如下:副本数量不能超过您拥有的节点数量。主题和分区的数量不受群集中节点数量的影响

    例如:

  • 您有9个节点的群集
  • 您的主题可以有9个分区和9个副本,或者
    18个分区和9个副本或
    36个分区和9个副本等...