在Kafka中创建主题的最佳方法是什么?
在新的生产者API中,当我尝试将消息发布到不存在的主题时,它第一次失败,然后成功发布。
请您参考如下方法:
启动Kafka代理时,可以在conf/server.properties
文件中定义属性集。该文件只是键值属性文件。属性之一是auto.create.topics.enable
,如果将其设置为true(默认情况下),则当您将消息发送到不存在的主题时,Kafka将自动创建主题。
您可以找到的所有配置选项均已定义here。恕我直言,创建主题的简单规则如下:副本数量不能超过您拥有的节点数量。主题和分区的数量不受群集中节点数量的影响
例如:
18个分区和9个副本或
36个分区和9个副本等...