sarama-cluster

cli log

go run cmd/sarama-cluster-cli/main.go -brokers="192.168.100.67:9091" -group="bsm" -offset="oldest" -topics="test.4" -verbose=true
2016/02/09 09:23:36 Initializing new client
2016/02/09 09:23:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9091 (unregistered)
2016/02/09 09:23:36 client/brokers registered new broker #9091 at 192.168.100.67:9091
2016/02/09 09:23:36 client/brokers registered new broker #9095 at 192.168.100.67:9095
2016/02/09 09:23:36 client/brokers registered new broker #9094 at 192.168.100.67:9094
2016/02/09 09:23:36 client/brokers registered new broker #9093 at 192.168.100.67:9093
2016/02/09 09:23:36 client/brokers registered new broker #9092 at 192.168.100.67:9092
2016/02/09 09:23:36 Successfully initialized new client
2016/02/09 09:23:36 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:23:36 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:23:36 cluster/consumer  rebalance
2016/02/09 09:23:36 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9094 (registered as #9094)
2016/02/09 09:23:36 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:23:36 cluster/consumer -36994bf8-1725-4857-872a-dcbf0a43bea1 consume test.4/0 from 2
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9095 (registered as #9095)
2016/02/09 09:23:36 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:23:36 cluster/consumer -36994bf8-1725-4857-872a-dcbf0a43bea1 consume test.4/1 from 3
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9091 (registered as #9091)
2016/02/09 09:23:36 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:23:36 cluster/consumer -36994bf8-1725-4857-872a-dcbf0a43bea1 consume test.4/2 from 3
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9092 (registered as #9092)
2016/02/09 09:23:36 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:23:36 cluster/consumer -36994bf8-1725-4857-872a-dcbf0a43bea1 consume test.4/3 from 2
2016/02/09 09:23:36 Connected to broker at 192.168.100.67:9093 (registered as #9093)
2016/02/09 09:23:36 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:32:49 kafka server: The provided member is not known in the current generation.
2016/02/09 09:32:49 cluster/consumer -36994bf8-1725-4857-872a-dcbf0a43bea1 rebalance
2016/02/09 09:32:49 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:32:49 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:32:49 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:32:49 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:32:49 consumer/broker/9095 closed dead subscription to test.4/0
2016/02/09 09:32:49 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:32:50 kafka server: The provided member is not known in the current generation.
2016/02/09 09:32:50 cluster/consumer  rebalance
2016/02/09 09:32:50 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:32:50 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:32:51 cluster/consumer -49767de1-98ba-47f3-8a3e-b3d9aefbfe52 consume test.4/0 from -2
2016/02/09 09:32:51 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:32:51 cluster/consumer -49767de1-98ba-47f3-8a3e-b3d9aefbfe52 consume test.4/1 from -2
test.4/0/0	3
test.4/0/1	7
2016/02/09 09:32:51 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:32:51 cluster/consumer -49767de1-98ba-47f3-8a3e-b3d9aefbfe52 consume test.4/2 from -2
2016/02/09 09:32:52 cluster/consumer -49767de1-98ba-47f3-8a3e-b3d9aefbfe52 consume test.4/3 from -2
2016/02/09 09:32:52 consumer/broker/9092 added subscription to test.4/2
test.4/2/0	0
test.4/2/1	4
test.4/2/2	8
2016/02/09 09:32:52 consumer/broker/9093 added subscription to test.4/3
test.4/3/0	2
test.4/3/1	6
test.4/1/0	1
test.4/1/1	5
test.4/1/2	9
2016/02/09 09:32:59 consumer/broker/9095 abandoned subscription to test.4/0 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:33:01 consumer/test.4/0 finding new broker
2016/02/09 09:33:01 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:33:02 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:33:07 kafka server: The provided member is not known in the current generation.
2016/02/09 09:33:07 cluster/consumer -49767de1-98ba-47f3-8a3e-b3d9aefbfe52 rebalance
2016/02/09 09:33:07 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:33:07 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:33:07 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:33:07 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:33:07 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:33:07 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:33:07 kafka server: The provided member is not known in the current generation.
2016/02/09 09:33:08 cluster/consumer  rebalance
2016/02/09 09:33:08 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:33:08 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:33:08 cluster/consumer -4356b587-93fa-485a-b759-58093d9f9811 consume test.4/0 from 2
2016/02/09 09:33:09 cluster/consumer -4356b587-93fa-485a-b759-58093d9f9811 consume test.4/1 from 3
2016/02/09 09:33:09 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:33:09 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:33:09 cluster/consumer -4356b587-93fa-485a-b759-58093d9f9811 consume test.4/2 from 3
2016/02/09 09:33:09 cluster/consumer -4356b587-93fa-485a-b759-58093d9f9811 consume test.4/3 from 2
2016/02/09 09:33:09 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:33:09 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:33:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 09:37:37 kafka server: The provided member is not known in the current generation.
2016/02/09 09:37:37 cluster/consumer -4356b587-93fa-485a-b759-58093d9f9811 rebalance
2016/02/09 09:37:37 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:37:38 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:37:38 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:37:38 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:37:38 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:37:39 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:37:41 kafka server: The provided member is not known in the current generation.
2016/02/09 09:37:41 cluster/consumer  rebalance
2016/02/09 09:37:41 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:37:41 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:37:44 cluster/consumer -f5218111-cd49-4104-80b6-4b68647d1dd9 consume test.4/0 from 2
2016/02/09 09:37:44 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:37:44 cluster/consumer -f5218111-cd49-4104-80b6-4b68647d1dd9 consume test.4/1 from 3
2016/02/09 09:37:44 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:37:44 cluster/consumer -f5218111-cd49-4104-80b6-4b68647d1dd9 consume test.4/2 from 3
2016/02/09 09:37:44 cluster/consumer -f5218111-cd49-4104-80b6-4b68647d1dd9 consume test.4/3 from 2
2016/02/09 09:37:44 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:37:44 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:37:53 consumer/broker/9092 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:37:55 consumer/test.4/2 finding new broker
2016/02/09 09:37:55 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:37:56 consumer/broker/9091 added subscription to test.4/2
2016/02/09 09:38:23 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:23 cluster/consumer -f5218111-cd49-4104-80b6-4b68647d1dd9 rebalance
2016/02/09 09:38:23 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:24 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:38:24 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:38:24 consumer/broker/9091 closed dead subscription to test.4/2
2016/02/09 09:38:24 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:38:24 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:38:24 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:25 cluster/consumer  rebalance
2016/02/09 09:38:25 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:25 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:38:26 cluster/consumer -0a6ba14b-94a7-40d0-bb15-6ff71f93ec0f consume test.4/0 from 2
2016/02/09 09:38:26 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:38:26 cluster/consumer -0a6ba14b-94a7-40d0-bb15-6ff71f93ec0f consume test.4/1 from 3
2016/02/09 09:38:26 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:38:26 cluster/consumer -0a6ba14b-94a7-40d0-bb15-6ff71f93ec0f consume test.4/2 from 3
2016/02/09 09:38:26 cluster/consumer -0a6ba14b-94a7-40d0-bb15-6ff71f93ec0f consume test.4/3 from 2
2016/02/09 09:38:26 consumer/broker/9091 added subscription to test.4/2
2016/02/09 09:38:26 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:38:28 consumer/broker/9091 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:38:30 consumer/broker/9091 abandoned subscription to test.4/1 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:38:30 consumer/test.4/2 finding new broker
2016/02/09 09:38:30 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:38:31 consumer/broker/9093 added subscription to test.4/2
2016/02/09 09:38:32 consumer/test.4/1 finding new broker
2016/02/09 09:38:32 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:38:32 consumer/broker/9092 added subscription to test.4/1
2016/02/09 09:38:51 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:51 cluster/consumer -0a6ba14b-94a7-40d0-bb15-6ff71f93ec0f rebalance
2016/02/09 09:38:51 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:51 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:38:51 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:38:51 consumer/broker/9093 closed dead subscription to test.4/2
2016/02/09 09:38:51 consumer/broker/9092 closed dead subscription to test.4/1
2016/02/09 09:38:51 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:38:51 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:52 cluster/consumer  rebalance
2016/02/09 09:38:52 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:52 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:38:53 cluster/consumer -1818368c-5cc0-4ac4-ac6c-e4ac05fa6081 consume test.4/0 from 2
2016/02/09 09:38:54 cluster/consumer -1818368c-5cc0-4ac4-ac6c-e4ac05fa6081 consume test.4/1 from 3
2016/02/09 09:38:54 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:38:54 cluster/consumer -1818368c-5cc0-4ac4-ac6c-e4ac05fa6081 consume test.4/2 from 3
2016/02/09 09:38:54 consumer/broker/9092 added subscription to test.4/1
2016/02/09 09:38:54 consumer/broker/9093 added subscription to test.4/2
2016/02/09 09:38:54 cluster/consumer -1818368c-5cc0-4ac4-ac6c-e4ac05fa6081 consume test.4/3 from 2
2016/02/09 09:38:55 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:38:58 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:58 cluster/consumer -1818368c-5cc0-4ac4-ac6c-e4ac05fa6081 rebalance
2016/02/09 09:38:58 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:58 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:38:58 consumer/broker/9092 closed dead subscription to test.4/1
2016/02/09 09:38:58 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:38:59 consumer/broker/9093 closed dead subscription to test.4/2
2016/02/09 09:38:59 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:38:59 kafka server: The provided member is not known in the current generation.
2016/02/09 09:38:59 cluster/consumer  rebalance
2016/02/09 09:38:59 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:38:59 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:00 cluster/consumer -8b7bb040-3b72-45aa-b24f-d17ce137fb66 consume test.4/0 from 2
2016/02/09 09:39:00 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:39:00 cluster/consumer -8b7bb040-3b72-45aa-b24f-d17ce137fb66 consume test.4/1 from 3
2016/02/09 09:39:00 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:39:00 cluster/consumer -8b7bb040-3b72-45aa-b24f-d17ce137fb66 consume test.4/2 from 3
2016/02/09 09:39:00 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:39:00 consumer/broker/9093 added subscription to test.4/2
2016/02/09 09:39:00 cluster/consumer -8b7bb040-3b72-45aa-b24f-d17ce137fb66 consume test.4/3 from 2
2016/02/09 09:39:01 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:39:06 consumer/broker/9094 abandoned subscription to test.4/0 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:39:07 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:07 cluster/consumer -8b7bb040-3b72-45aa-b24f-d17ce137fb66 rebalance
2016/02/09 09:39:07 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:07 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:07 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:39:07 consumer/broker/9093 closed dead subscription to test.4/2
2016/02/09 09:39:07 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:39:08 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:08 cluster/consumer  rebalance
2016/02/09 09:39:08 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:08 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:09 kafka server: Request was for a consumer group that is not coordinated by this broker.
2016/02/09 09:39:09 cluster/consumer -049b4861-55b6-4b11-8d45-4779e967a6ad rebalance
2016/02/09 09:39:09 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:09 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:09 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:10 cluster/consumer  rebalance
2016/02/09 09:39:10 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:10 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:10 cluster/consumer -d717dd0e-7007-4a69-8a38-7169f969e3e3 consume test.4/0 from 2
2016/02/09 09:39:10 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:39:10 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:39:10 cluster/consumer -d717dd0e-7007-4a69-8a38-7169f969e3e3 consume test.4/1 from 3
2016/02/09 09:39:11 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:39:11 cluster/consumer -d717dd0e-7007-4a69-8a38-7169f969e3e3 consume test.4/2 from 3
2016/02/09 09:39:11 cluster/consumer -d717dd0e-7007-4a69-8a38-7169f969e3e3 consume test.4/3 from 2
2016/02/09 09:39:11 consumer/broker/9093 added subscription to test.4/2
2016/02/09 09:39:12 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:39:15 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:15 cluster/consumer -d717dd0e-7007-4a69-8a38-7169f969e3e3 rebalance
2016/02/09 09:39:15 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:17 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:17 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:39:17 consumer/broker/9093 closed dead subscription to test.4/2
2016/02/09 09:39:17 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:39:17 consumer/broker/9095 closed dead subscription to test.4/0
2016/02/09 09:39:17 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:17 cluster/consumer  rebalance
2016/02/09 09:39:17 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:17 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:18 cluster/consumer -3b95b377-9fa6-4279-bd0c-48d748a00265 consume test.4/0 from 2
2016/02/09 09:39:18 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:39:18 cluster/consumer -3b95b377-9fa6-4279-bd0c-48d748a00265 consume test.4/1 from 3
2016/02/09 09:39:18 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:39:18 cluster/consumer -3b95b377-9fa6-4279-bd0c-48d748a00265 consume test.4/2 from 3
2016/02/09 09:39:18 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:39:18 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:39:18 cluster/consumer -3b95b377-9fa6-4279-bd0c-48d748a00265 consume test.4/3 from 2
2016/02/09 09:39:18 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:39:27 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:27 cluster/consumer -3b95b377-9fa6-4279-bd0c-48d748a00265 rebalance
2016/02/09 09:39:27 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:27 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:27 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:39:27 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:39:28 consumer/broker/9095 closed dead subscription to test.4/0
2016/02/09 09:39:28 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:39:28 kafka server: The provided member is not known in the current generation.
2016/02/09 09:39:28 cluster/consumer  rebalance
2016/02/09 09:39:28 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:39:28 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:39:32 cluster/consumer -f7cf013e-1751-4c37-a450-e41a820f97ff consume test.4/0 from 2
2016/02/09 09:39:33 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:39:33 cluster/consumer -f7cf013e-1751-4c37-a450-e41a820f97ff consume test.4/1 from 3
2016/02/09 09:39:34 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:39:34 cluster/consumer -f7cf013e-1751-4c37-a450-e41a820f97ff consume test.4/2 from 3
2016/02/09 09:39:35 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:39:35 cluster/consumer -f7cf013e-1751-4c37-a450-e41a820f97ff consume test.4/3 from 2
2016/02/09 09:39:36 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:40:18 kafka server: The provided member is not known in the current generation.
2016/02/09 09:40:18 cluster/consumer -f7cf013e-1751-4c37-a450-e41a820f97ff rebalance
2016/02/09 09:40:18 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:40:18 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:40:18 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:40:19 consumer/broker/9095 closed dead subscription to test.4/0
2016/02/09 09:40:19 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:40:19 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:40:19 kafka server: The provided member is not known in the current generation.
2016/02/09 09:40:20 cluster/consumer  rebalance
2016/02/09 09:40:20 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:40:20 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:40:21 cluster/consumer -a6274641-2890-46dd-ac27-6b251f5999ef consume test.4/0 from 2
2016/02/09 09:40:22 cluster/consumer -a6274641-2890-46dd-ac27-6b251f5999ef consume test.4/1 from 3
2016/02/09 09:40:22 consumer/broker/9095 added subscription to test.4/0
2016/02/09 09:40:22 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:40:22 cluster/consumer -a6274641-2890-46dd-ac27-6b251f5999ef consume test.4/2 from 3
2016/02/09 09:40:22 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:40:22 cluster/consumer -a6274641-2890-46dd-ac27-6b251f5999ef consume test.4/3 from 2
2016/02/09 09:40:23 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:40:37 consumer/broker/9091 abandoned subscription to test.4/1 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:40:39 consumer/test.4/1 finding new broker
2016/02/09 09:40:39 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:40:39 consumer/broker/9092 added subscription to test.4/1
2016/02/09 09:40:44 kafka server: The provided member is not known in the current generation.
2016/02/09 09:40:44 cluster/consumer -a6274641-2890-46dd-ac27-6b251f5999ef rebalance
2016/02/09 09:40:44 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:40:44 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:40:44 consumer/broker/9095 closed dead subscription to test.4/0
2016/02/09 09:40:44 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:40:44 consumer/broker/9092 closed dead subscription to test.4/1
2016/02/09 09:40:45 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:40:45 kafka server: The provided member is not known in the current generation.
2016/02/09 09:40:45 cluster/consumer  rebalance
2016/02/09 09:40:45 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:40:45 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:40:46 cluster/consumer -536f3ab3-b2ae-482f-ae5e-eab333a4287b consume test.4/0 from 2
2016/02/09 09:40:46 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:40:46 cluster/consumer -536f3ab3-b2ae-482f-ae5e-eab333a4287b consume test.4/1 from 3
2016/02/09 09:40:46 consumer/broker/9092 added subscription to test.4/1
2016/02/09 09:40:46 cluster/consumer -536f3ab3-b2ae-482f-ae5e-eab333a4287b consume test.4/2 from 3
2016/02/09 09:40:48 cluster/consumer -536f3ab3-b2ae-482f-ae5e-eab333a4287b consume test.4/3 from 2
2016/02/09 09:40:48 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:40:49 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:41:16 kafka server: The provided member is not known in the current generation.
2016/02/09 09:41:16 cluster/consumer -536f3ab3-b2ae-482f-ae5e-eab333a4287b rebalance
2016/02/09 09:41:16 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:41:16 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:41:16 consumer/broker/9092 closed dead subscription to test.4/1
2016/02/09 09:41:16 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:41:16 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:41:16 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:41:16 kafka server: The provided member is not known in the current generation.
2016/02/09 09:41:16 cluster/consumer  rebalance
2016/02/09 09:41:16 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:41:16 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:41:17 cluster/consumer -feb9ae8a-0874-4905-8c9b-1140a12eccd9 consume test.4/0 from 2
2016/02/09 09:41:17 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:41:17 cluster/consumer -feb9ae8a-0874-4905-8c9b-1140a12eccd9 consume test.4/1 from 3
2016/02/09 09:41:17 consumer/broker/9092 added subscription to test.4/1
2016/02/09 09:41:17 cluster/consumer -feb9ae8a-0874-4905-8c9b-1140a12eccd9 consume test.4/2 from 3
2016/02/09 09:41:17 cluster/consumer -feb9ae8a-0874-4905-8c9b-1140a12eccd9 consume test.4/3 from 2
2016/02/09 09:41:17 consumer/broker/9093 added subscription to test.4/3
2016/02/09 09:41:17 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:43:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 09:43:48 consumer/broker/9092 abandoned subscription to test.4/1 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 09:43:50 consumer/test.4/1 finding new broker
2016/02/09 09:43:50 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 09:43:50 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:43:50 kafka server: The provided member is not known in the current generation.
2016/02/09 09:43:50 cluster/consumer -feb9ae8a-0874-4905-8c9b-1140a12eccd9 rebalance
2016/02/09 09:43:50 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:43:50 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:43:51 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 09:43:51 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 09:43:51 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 09:43:51 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 09:43:51 kafka server: The provided member is not known in the current generation.
2016/02/09 09:43:51 cluster/consumer  rebalance
2016/02/09 09:43:51 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 09:43:51 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 09:43:51 cluster/consumer -2edb02ab-d393-4895-868e-a1d5f9c3d37c consume test.4/0 from -2
2016/02/09 09:43:51 consumer/broker/9094 added subscription to test.4/0
2016/02/09 09:43:51 cluster/consumer -2edb02ab-d393-4895-868e-a1d5f9c3d37c consume test.4/1 from -2
2016/02/09 09:43:51 consumer/broker/9091 added subscription to test.4/1
2016/02/09 09:43:51 cluster/consumer -2edb02ab-d393-4895-868e-a1d5f9c3d37c consume test.4/2 from -2
test.4/0/0	3
test.4/0/1	7
test.4/1/0	1
test.4/1/1	5
test.4/1/2	9
2016/02/09 09:43:51 consumer/broker/9092 added subscription to test.4/2
2016/02/09 09:43:51 cluster/consumer -2edb02ab-d393-4895-868e-a1d5f9c3d37c consume test.4/3 from -2
test.4/2/0	0
test.4/2/1	4
test.4/2/2	8
2016/02/09 09:43:51 consumer/broker/9093 added subscription to test.4/3
test.4/3/0	2
test.4/3/1	6
2016/02/09 09:53:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:01:51 kafka server: The provided member is not known in the current generation.
2016/02/09 10:01:51 cluster/consumer -2edb02ab-d393-4895-868e-a1d5f9c3d37c rebalance
2016/02/09 10:01:51 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:01:52 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:01:52 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:01:52 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 10:01:52 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 10:01:52 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 10:01:52 kafka server: The provided member is not known in the current generation.
2016/02/09 10:01:52 cluster/consumer  rebalance
2016/02/09 10:01:52 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:01:52 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:01:58 cluster/consumer -3a7e8dca-ad11-4eee-abbd-bd5d515e7e55 consume test.4/0 from -2
2016/02/09 10:01:58 consumer/broker/9094 added subscription to test.4/0
2016/02/09 10:01:58 cluster/consumer -3a7e8dca-ad11-4eee-abbd-bd5d515e7e55 consume test.4/1 from -2
2016/02/09 10:01:58 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:01:58 cluster/consumer -3a7e8dca-ad11-4eee-abbd-bd5d515e7e55 consume test.4/2 from -2
test.4/0/0	3
test.4/0/1	7
test.4/1/0	1
test.4/1/1	5
test.4/1/2	9
2016/02/09 10:01:59 consumer/broker/9092 added subscription to test.4/2
2016/02/09 10:01:59 cluster/consumer -3a7e8dca-ad11-4eee-abbd-bd5d515e7e55 consume test.4/3 from -2
2016/02/09 10:01:59 consumer/broker/9092 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:02:01 consumer/broker/9093 added subscription to test.4/3
test.4/3/0	2
test.4/3/1	6
2016/02/09 10:02:01 consumer/test.4/2 finding new broker
2016/02/09 10:02:01 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:02:02 consumer/broker/9091 added subscription to test.4/2
test.4/2/0	0
test.4/2/1	4
test.4/2/2	8
2016/02/09 10:03:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:03:58 kafka server: The provided member is not known in the current generation.
2016/02/09 10:03:58 cluster/consumer -3a7e8dca-ad11-4eee-abbd-bd5d515e7e55 rebalance
2016/02/09 10:03:58 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:03:58 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:03:58 consumer/broker/9091 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:03:58 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:03:58 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 10:03:58 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 10:03:58 kafka server: The provided member is not known in the current generation.
2016/02/09 10:03:59 cluster/consumer  rebalance
2016/02/09 10:03:59 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:04:16 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:04:19 cluster/consumer -a38b5d30-1f11-44aa-8793-6dab8152cb59 consume test.4/0 from 2
2016/02/09 10:04:19 consumer/broker/9094 added subscription to test.4/0
2016/02/09 10:04:19 cluster/consumer -a38b5d30-1f11-44aa-8793-6dab8152cb59 consume test.4/1 from 3
2016/02/09 10:04:19 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:04:19 cluster/consumer -a38b5d30-1f11-44aa-8793-6dab8152cb59 consume test.4/2 from 3
2016/02/09 10:04:19 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:04:20 consumer/broker/9092 added subscription to test.4/2
2016/02/09 10:04:20 cluster/consumer -a38b5d30-1f11-44aa-8793-6dab8152cb59 consume test.4/3 from 2
2016/02/09 10:04:20 consumer/broker/9093 added subscription to test.4/3
2016/02/09 10:12:22 kafka server: The provided member is not known in the current generation.
2016/02/09 10:12:22 cluster/consumer -a38b5d30-1f11-44aa-8793-6dab8152cb59 rebalance
2016/02/09 10:12:22 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:12:32 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:12:32 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:12:32 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 10:12:33 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 10:12:35 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 10:12:36 kafka server: The provided member is not known in the current generation.
2016/02/09 10:12:36 cluster/consumer  rebalance
2016/02/09 10:12:36 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:12:37 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:13:07 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/0 from -2
2016/02/09 10:13:07 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/1 from -2
2016/02/09 10:13:07 consumer/broker/9094 added subscription to test.4/0
test.4/0/0	3
test.4/0/1	7
2016/02/09 10:13:07 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:13:07 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/2 from -2
test.4/1/0	1
test.4/1/1	5
test.4/1/2	9
2016/02/09 10:13:07 consumer/broker/9092 added subscription to test.4/2
2016/02/09 10:13:07 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/3 from -2
2016/02/09 10:13:07 consumer/broker/9093 added subscription to test.4/3
test.4/2/0	0
test.4/2/1	4
test.4/2/2	8
test.4/3/0	2
test.4/3/1	6
2016/02/09 10:13:36 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:13:39 client/metadata found some partitions to be leaderless
2016/02/09 10:13:39 client/metadata retrying after 250ms... (3 attempts remaining)
2016/02/09 10:13:40 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:13:41 client/metadata found some partitions to be leaderless
2016/02/09 10:13:41 client/metadata retrying after 250ms... (2 attempts remaining)
2016/02/09 10:13:42 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:13:44 client/metadata found some partitions to be leaderless
2016/02/09 10:13:44 client/metadata retrying after 250ms... (1 attempts remaining)
2016/02/09 10:13:45 client/metadata fetching metadata for all topics from broker 192.168.100.67:9091
2016/02/09 10:13:49 client/metadata found some partitions to be leaderless
2016/02/09 10:13:59 consumer/broker/9094 abandoned subscription to test.4/0 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:14:01 consumer/test.4/0 finding new broker
2016/02/09 10:14:01 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:01 client/metadata found some partitions to be leaderless
2016/02/09 10:14:01 client/metadata retrying after 250ms... (3 attempts remaining)
2016/02/09 10:14:01 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:01 client/metadata found some partitions to be leaderless
2016/02/09 10:14:01 client/metadata retrying after 250ms... (2 attempts remaining)
2016/02/09 10:14:01 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e rebalance
2016/02/09 10:14:01 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:14:01 client/coordinator coordinator for consumergoup bsm is #9091 (192.168.100.67:9091)
2016/02/09 10:14:01 consumer/broker/9092 closed dead subscription to test.4/2
2016/02/09 10:14:01 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:01 consumer/broker/9093 closed dead subscription to test.4/3
2016/02/09 10:14:01 client/metadata found some partitions to be leaderless
2016/02/09 10:14:01 client/metadata retrying after 250ms... (1 attempts remaining)
2016/02/09 10:14:01 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:14:02 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:02 consumer/broker/9091 added subscription to test.4/0
2016/02/09 10:14:02 consumer/broker/9091 closed dead subscription to test.4/0
2016/02/09 10:14:04 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/0 from 2
2016/02/09 10:14:04 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/1 from 3
2016/02/09 10:14:04 consumer/broker/9091 added subscription to test.4/0
2016/02/09 10:14:04 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/2 from 3
2016/02/09 10:14:04 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:14:04 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/3 from 2
2016/02/09 10:14:04 consumer/broker/9094 added subscription to test.4/3
2016/02/09 10:14:04 consumer/broker/9091 added subscription to test.4/2
2016/02/09 10:14:43 consumer/broker/9091 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:14:43 consumer/broker/9091 abandoned subscription to test.4/0 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:14:43 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e rebalance
2016/02/09 10:14:43 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:14:43 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:14:44 consumer/broker/9094 closed dead subscription to test.4/3
2016/02/09 10:14:44 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:14:44 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/0 from 2
2016/02/09 10:14:44 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:44 client/metadata found some partitions to be leaderless
2016/02/09 10:14:44 client/metadata retrying after 250ms... (3 attempts remaining)
2016/02/09 10:14:44 client/metadata fetching metadata for [test.4] from broker 192.168.100.67:9091
2016/02/09 10:14:44 consumer/broker/9094 added subscription to test.4/0
2016/02/09 10:14:44 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/1 from 3
2016/02/09 10:14:44 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/2 from 3
2016/02/09 10:14:44 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:14:45 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e consume test.4/3 from 2
2016/02/09 10:14:45 consumer/broker/9091 added subscription to test.4/2
2016/02/09 10:14:45 consumer/broker/9094 added subscription to test.4/3
2016/02/09 10:14:50 consumer/broker/9091 abandoned subscription to test.4/2 because kafka server: Tried to send a message to a replica that is not the leader for some partition. Your metadata is out of date.
2016/02/09 10:14:52 kafka server: The provided member is not known in the current generation.
2016/02/09 10:14:52 cluster/consumer -2a758d41-ecb3-4e40-9f0b-efc33924372e rebalance
2016/02/09 10:14:52 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:14:52 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:14:52 consumer/broker/9091 closed dead subscription to test.4/1
2016/02/09 10:14:52 consumer/broker/9094 closed dead subscription to test.4/0
2016/02/09 10:14:52 consumer/broker/9094 closed dead subscription to test.4/3
2016/02/09 10:14:52 kafka server: The provided member is not known in the current generation.
2016/02/09 10:14:53 cluster/consumer  rebalance
2016/02/09 10:14:53 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:14:53 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:15:02 kafka server: Request exceeded the user-specified time limit in the request.
2016/02/09 10:15:02 cluster/consumer -13d4465d-91b5-43c1-b8bb-66c880d24832 rebalance
2016/02/09 10:15:02 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:15:02 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:15:03 kafka server: The provided member is not known in the current generation.
2016/02/09 10:15:03 cluster/consumer  rebalance
2016/02/09 10:15:03 client/coordinator requesting coordinator for consumergoup bsm from 192.168.100.67:9091
2016/02/09 10:15:03 client/coordinator coordinator for consumergoup bsm is #9094 (192.168.100.67:9094)
2016/02/09 10:15:05 cluster/consumer -765215bc-4e09-4765-86b9-781ab0da8d2c consume test.4/0 from 2
2016/02/09 10:15:05 consumer/broker/9094 added subscription to test.4/0
2016/02/09 10:15:05 cluster/consumer -765215bc-4e09-4765-86b9-781ab0da8d2c consume test.4/1 from 3
2016/02/09 10:15:05 consumer/broker/9091 added subscription to test.4/1
2016/02/09 10:15:05 cluster/consumer -765215bc-4e09-4765-86b9-781ab0da8d2c consume test.4/2 from 3
2016/02/09 10:15:05 cluster/consumer -765215bc-4e09-4765-86b9-781ab0da8d2c consume test.4/3 from 2
2016/02/09 10:15:05 consumer/broker/9091 added subscription to test.4/2
2016/02/09 10:15:06 consumer/broker/9094 added subscription to test.4/3