如果获取到了则执行通知流程notificationHandler.processNotification(d),处理器是ConfigChangedNotificationHandler;

」的方式4分区副本重分配方式分区副本重分配的源码解析过程请看：3万字长文呕心沥血教你彻底搞懂数据迁移原理(附配套教学视频)这里就不再赘述了,直接抛出结果;我们把上面扩容之后的topic

replicaStateMachine.handleStateChanges(controllerContext.replicasForPartition(newPartitions).toSeq,

Controller监听/admin/reassign_partitions节点变化KafkaController.processZkPartitionReassignmentprivate

执行--execute如果你想在重新平衡期间修改限制，增加吞吐量，以便完成的更快。你可以重新运行execute命令，用相同的reassignment-json-file:2.1.2

topics3.查询Topic的详细配置(动态+静态)只需要加上一个参数--all其他配置/clients/users/brokers/broker-loggers

查看发送的消息相关可选参数参数描述例子--topic指定消费的topic--num-records发送多少条消息--throughput每秒消息最大吞吐量--producer-props生产者配置,