受此博文啟發：
以單副本，3分割槽示例：
kafka在zk中存放路徑為 / （路徑自行驗證）
1、檢視kafka的topic詳細資訊
2、檢視zk節點
指定節點內部為空。
檢視其它同級節點發現有分割槽資訊：
3、建立分割槽資訊
進入zookeeper-client：
首先檢視節點/controller_epoch的值：
get /controller_epoch
得到值1
create /brokers/topics/testdelete3/partitions null根據第一步中的分割槽情況，共有0,1,2三個分割槽，分別建立這三個節點create /brokers/topics/testdelete3/partitions/0 nullcreate /brokers/topics/testdelete3/partitions/1 nullcreate /brokers/topics/testdelete3/partitions/2 null create /brokers/topics/testdelete3/partitions/0/state
create /brokers/topics/testdelete3/partitions/1/state create /brokers/topics/testdelete3/partitions/2/state
4、檢視leader
5、生產消費檢驗
生產資料./kafka-console-producer.sh –broker-list dev-kafka01:6667,dev-kafka02:6667,dev-kafka03:6667 –topic testdelete3
消費資料：/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh –zookeeper dev-zookeeper01:2181 –topic testdelete3
生產可以正常生產，並且在消費端可以正常消費即可。
ROS對topic進行幀率的變化，以及顯示
git clone 對其進行catkin make編譯以及加入環境變數即可,是乙個ros package。2.把左右相機的資料幀率降到4 rosrun topic tools throttle messages mynteye right image raw 4 這條指令會預設的建立乙個新的幀率為4...
副本的leader選舉
kafka提供了資料複製演算法保證，如果leader副本所在的broker節點宕機或者出現故障，或者分割槽的leader節點發生故障，這個時候怎麼處理呢？那麼，kafka必須要保證從follower副本中選擇乙個新的leader副本。那麼kafka是如何實現選舉的呢？要了解leader選舉，我們需要...
副本的leader選舉
kafka提供了資料複製演算法保證，如果leader副本所在的broker節點宕機或者出現故障，或者分割槽的leader節點發生故障，這個時候怎麼處理呢？那麼，kafka必須要保證從follower副本中選擇乙個新的leader副本。那麼kafka是如何實現選舉的呢？要了解leader選舉，我們需要...