1、檢視推送程式物理機連線kafka埠6667的TCP連線，確實只有一臺

     [[email protected]~]#  ss -anp |grep ':6667' |grep '11314'     (Linux檢視方式)
     tcp    ESTAB      0      0      ::ffff:172.16.10.133:43760      ::ffff:172.16.10.166:6667         users:(("java",pid=11314,fd=551))
     C:\Users\jun>netstat -n |findstr ":6667"           (Windows檢視方式)
     TCP    172.16.80.126:59795    172.16.10.166:6667     ESTABLISHED

2、檢視topic分配的分割槽和Broker選擇Leader也都只有一臺borker=1001

      [[email protected] ~]# /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --describe --zookeeper 172.16.10.158:2181 --topic BuB
         Topic: BuB	PartitionCount:4	ReplicationFactor:4	         Configs:
	 Topic: BuB	Partition: 0	        Leader: 1001	 Replicas: 1001	Isr: 1001
	 Topic: BuB	Partition: 1	        Leader: 1001     Replicas: 1001	Isr: 1001
	 Topic: BuB	Partition: 2	        Leader: 1001     Replicas: 1001	Isr: 1001
	 Topic: BuB	Partition: 3	        Leader: 1001	 Replicas: 1001	Isr: 1001
 

3、如何讓Kafka叢集啟到多個Broker節點負載均衡的作用呢？

在 Kafka 叢集中，我們可以對每個 Topic 進行一個或是多個分割槽，併為該 Topic 指定備份數，指定備份數的時候，備份數要小於等於 Brokers 數。否則建立失敗。

其中為什麼備份數要小於等於Broker數，探究其中奧祕，修改備份引數：default.replication.factor=1個修改成了4個備份，Leader的選舉變成了4臺，

在重新整理物理機推送訊息與物理機的TCP連線，現在變成了4臺：

[[email protected]~]# ss -anp |grep ':6667' |grep 'pid=11314'
tcp    ESTAB      0      0      ::ffff:172.16.10.133:43760              ::ffff:172.16.10.166:6667                users:(("java",pid=11314,fd=551))
tcp    ESTAB      0      0      ::ffff:172.16.10.133:52254              ::ffff:172.16.10.168:6667                users:(("java",pid=11314,fd=549))
tcp    ESTAB      0      0      ::ffff:172.16.10.133:51814              ::ffff:172.16.10.167:6667                users:(("java",pid=11314,fd=548))
tcp    ESTAB      0      0      ::ffff:172.16.10.133:54038              ::ffff:172.16.10.169:6667                users:(("java",pid=11314,fd=550))
 

[[email protected]~]# /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --describe --zookeeper 172.16.10.158:2181 --topic BuB
Topic:BuB	PartitionCount:4	ReplicationFactor:4	Configs:
Topic: BuB	Partition: 0	Leader: 1001	Replicas: 1001,1002,1003,1004	Isr: 1001,1004,1002,1003
Topic: BuB	Partition: 1	Leader: 1002	Replicas: 1002,1003,1004,1001	Isr: 1002,1001,1004,1003
Topic: BuB	Partition: 2	Leader: 1003	Replicas: 1003,1004,1001,1002	Isr: 1003,1004,1002,1001
Topic: BuB	Partition: 3	Leader: 1004	Replicas: 1004,1001,1002,1003	Isr: 1004,1002,1001,1003

參考連結：http://www.cnblogs.com/smartloli/p/6012134.html

http://www.cnblogs.com/bonelee/p/6893286.html

總結：Kafka叢集Broker要起到負載均衡作用的效果，default.replication.factor 備份數必須>=2，若是很均衡所有Broker節點，那就備份數=Broker節點數 ，否則就能均衡數=備份數

手動敲命令新建topic是可以負載均衡，推測跟kafka叢集配置使用不當有關係

 ./kafka-topics.sh  --create --zookeeper 192.168.128.102:2181 --replication-factor 1  --partitions 2 --topic topic1 

最終排查，其實備份數只是備份多份資料用，是不會起到負載作用的，之所以會出現不負載這種場景，是因為在增加Borker節點的時候，加大分割槽數重啟Kafka服務，topic已分配好的分割槽數沒變更，所以直接通過Zookeeper命令刪除所有topic是不可取的(rmr /broker)，因為用命令直接刪除zookeeper資料會刪除不乾淨影響到kafka的leader負載均衡的選舉，之後通過kafka的delete命令刪除解決負載均衡的問題。

 ./kafka-topics.sh --delete --zookeeper 172.16.10.157:2181 --topic BuB # 刪除分割槽
 ./kafka-preferred-replica-election.sh --zookeeper 172.16.10.157:2181 # 重新分割槽

注意：如果是多個kafka的broker節點，要關閉其中幾個broker節點，通過kafka delete刪除還是無效，會提示刪除已被標誌了，要快速刪除，還是得到zookeeper上面進行直接刪除。

======================================================================================================================

之後發現一個問題：kafka重新啟動後，主題的分割槽分佈又重新分配，有的節點只有分配3個分割槽，有的節點分配5個分割槽。