we got three nodes in our kafka cluster,and I notice that after 2 of our consumers encountered session time out:
[2012-09-09 22:57:13,502] INFO Client session timed out, have not heard > from server in 4368ms for sessionid 0x338706f2acf72f5, closing socket > connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) > [2012-09-09 22:57:13,603] INFO zookeeper state changed (Disconnected) > (org.I0Itec.zkclient.ZkClient) > [2012-09-09 22:57:14,594] INFO Opening socket connection to server > unode22-ins-db1/10.18.10.32:2181 (org.apache.zookeeper.ClientCnxn) > [2012-09-09 22:57:14,595] INFO Socket connection established to > unode22-ins-db1/10.18.10.32:2181, initiating session > (org.apache.zookeeper.ClientCnxn) > [2012-09-09 22:57:14,596] INFO Session establishment complete on server > unode22-ins-db1/10.18.10.32:2181, sessionid = 0x338706f2acf72f5, > negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) > [2012-09-09 22:57:14,596] INFO zookeeper state changed (SyncConnected) > (org.I0Itec.zkclient.ZkClient) the partition ownership becomes quite un-even. number of consumers on these 3 nodes are: 14,12 and 16 well the actual partitions owned by these 3 nodes are(I check this use ConsumerOffsetChecker): 40,24 and 32 is this a expected behaviour after client session time out? -- Best Regards ---------------------- 刘明敏 | mmLiu
