【发布时间】:2020-05-08 13:33:54
【问题描述】:
我有以下关于 Kafka 的问题:
如果我创建一个主题并指定的分区数量多于代理数量,那么单个代理将处理超过 1 个分区?
如果我创建一个主题并指定复制因子多于没有代理,该主题是否会创建?
单个代理能否处理不同主题的多个分区。
【问题讨论】:
标签: apache-kafka
我有以下关于 Kafka 的问题:
如果我创建一个主题并指定的分区数量多于代理数量,那么单个代理将处理超过 1 个分区?
如果我创建一个主题并指定复制因子多于没有代理,该主题是否会创建?
单个代理能否处理不同主题的多个分区。
【问题讨论】:
标签: apache-kafka
+-------------------+
| Topic X |
| Partition 0 |
| |
| |
| Topic X |
| Partition 1 |
+-------------------+
--replication-factor 3 创建一个主题,并且只有一个可用的代理:>> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic myTestTopic
Error while executing topic command replication factor: 3 larger than available
brokers: 1
kafka.admin.AdminOperationException: replication factor: 3 larger than available
brokers: 1
at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
replication-factor=1。您的经纪人的示例概览如下所示: +-------------------+
| Topic 1 |
| Partition 0 |
| |
| |
| Topic 3 |
| Partition 1 |
| |
| |
| Topic 2 |
| Partition 1 |
+-------------------+
+-------------------+
| Topic 1 |
| Partition 1 |
| |
| |
| Topic 3 |
| Partition 0 |
| |
| |
| Topic 2 |
| Partition 0 |
+-------------------+
【讨论】:
祝你好运:D
【讨论】: