石臻臻的杂货铺

其他

听说你还在傻傻的关闭服务器去改配置?(附视频)

如果获取到了则执行通知流程notificationHandler.processNotification(d),处理器是ConfigChangedNotificationHandler;
2021年8月30日
其他

这可能是kafka的一个小bug.....

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

你知道Kafka创建Topic这个过程做了哪些事情吗?(附视频)

replicaStateMachine.handleStateChanges(controllerContext.replicasForPartition(newPartitions).toSeq,
2021年8月9日
其他

3万字长文呕心沥血教你彻底搞懂数据迁移原理(附配套教学视频)

Controller监听/admin/reassign_partitions节点变化KafkaController.processZkPartitionReassignmentprivate
2021年7月29日
其他

【kafka运维】你真的懂数据迁移吗?

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

【kafka运维】ConfigCommand命令详解(2)

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

【kafka运维】Kafka全网最全最详细运维命令合集(精品强烈建议收藏!!!)

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