当脚本给出分区和副本因子的详细信息时,将在代理中创建主题的位置和位置

问题描述 投票:0回答:2

当我们创建主题时,我们在其中决定分区数和复制因子。是否在所有经纪人中创建了此主题?它特定于任何一位经纪人吗?

apache-kafka kafka-producer-api
2个回答
0
投票

创建主题时,您必须传递复制因子和分区。

尽管每个分区和副本都放置了哪个代理,但是以后可以使用kafka-reassign-partitions将副本移动到其他代理。


0
投票

您可以使用此命令创建主题:

./bin/kafka-topics.sh --create --zookeeper <ZOOKEEPER_URL:PORT> --replication-factor <NO_OF_REPLICATIONS> --partitions <NO_OF_PARTITIONS> --topic <TOPIC_NAME>

此命令之后,有关主题的元数据(分区,副本,ISR列表等)存储在Zookeeper中。您可以通过以下命令获取有关主题的信息:

./bin/kafka-topics.sh --zookeeper localhost:2181 --topic TopicName --describe

分区的副本列表是根据循环算法创建的,Controller代理负责通知新主题的创建并触发分区的分配。

© www.soinside.com 2019 - 2024. All rights reserved.