Kafka中创建Topic时如何将分区放置到不同的Broker 中？

在 Kafka 中，分区的放置是由 Kafka 集群的分区分配策略（Partition Assignment Strategy）决定的。当你创建一个新的主题（Topic）并指定分区数量时，Kafka 会根据当前的分区分配策略将这些分区分布到不同的 Broker 上。

Kafka 提供了两种默认的分区分配策略：

1. Range分配策略（Range Assignment Strategy）：
   • Range 分配策略会将分区按照范围划分，并尽量均匀地分配到不同的 Broker 上。例如，如果有3个 Broker，而你创建了一个具有10个分区的主题，那么可能的分配方式是：
     • Broker 1: Partition 0-2
     • Broker 2: Partition 3-5
     • Broker 3: Partition 6-9
2. Round-robin分配策略：
   • Round-robin 分配策略简单地按照轮询的方式将分区分配给不同的 Broker。例如，如果有3个 Broker，而你创建了一个具有10个分区的主题，那么可能的分配方式是：
     • Broker 1: Partition 0, 3, 6, 9
     • Broker 2: Partition 1, 4, 7
     • Broker 3: Partition 2, 5, 8

Kafka 默认使用的是 Range 分配策略。你可以在创建主题时通过配置指定分区分配策略，或者在修改主题的分区数量时生效。以下是一个例子，在创建主题时指定 Round-robin 分配策略：

kafka-topics.sh --create --topic my_topic --partitions 10 --replication-factor 3 --config partition.assignment.strategy=org.apache.kafka.clients.admin.RoundRobinAssignor --bootstrap-server localhost:9092

在这个例子中，--config partition.assignment.strategy=org.apache.kafka.clients.admin.RoundRobinAssignor 指定了使用 Round-robin 分配策略。你可以根据具体需求选择合适的分区分配策略。注意，Kafka 还允许你自定义分区分配策略，但这需要编写自定义的 Java 类并在配置中指定。