关于Kafka topic creation . 我知道Kafka集群可以有几个代理/节点/服务器 . 每个代理可以配置一个或多个主题 . 根据主题创建期间提供的分区,创建的主题可以位于一个或多个代理中 . 有什么方法可以告诉我们哪个经纪人应该创建一个主题并创建它的分区?
问候,Lokesh
关于Kafka topic creation . 我知道Kafka集群可以有几个代理/节点/服务器 . 每个代理可以配置一个或多个主题 . 根据主题创建期间提供的分区,创建的主题可以位于一个或多个代理中 . 有什么方法可以告诉我们哪个经纪人应该创建一个主题并创建它的分区?
问候,Lokesh
1 回答
创建主题时,您可以只指定分区和副本的数量,然后让Kafka分发它们 . 或者您可以直接指定分配 - 哪个分区和副本去哪里 .
如果您正在使用属于kafka的
kafka-topics.sh
脚本,则可以使用选项--replica-assignment
. 例如:如果主题已存在,则可以使用
kafka-reassign-partitions.sh
工具更改分配 .这可能包含更多有关的详细信息:https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-2.2CreateTopics