2021-10-30分割槽訊息Broker消費者分配

如果使用同一個生產者往同一個分割槽寫入訊息，而且訊息B在訊息A之後寫入，那麼kafka可以保證訊息B的偏移量比訊息A的偏移量大，而且消費者會先讀取到訊息A再讀取訊息B...

2021-10-18ControllerBrokerZooKeeperKafkaLeader

標準做法也是透過kafka-reassign-partitions指令碼完成，不過使用者可直接往Zookeeper中寫資料來實現，比如直接把新增分割槽的副本集合寫入到/brokers/topics/下，然後controller會為你自動地選...