Is X.X.X.X:9092 up and accepting connections? I am confused aas in why is it not connecting some other broker if connection to this broker fails. Can you check if the broker is up?
The way it works is the consumer will send a ConsumerMetadataRequest to one of the brokers and get the offsetmanager for its group and then perform the offset management. Thanks, Mayuresh On Fri, May 8, 2015 at 9:22 AM, Meghana Narasimhan < mnarasim...@bandwidth.com> wrote: > Hi, > I'm using the Kafka 8.2.1 version(kafka_2.11-0.8.2.1) and the consumer > offset checker hangs indefinitely and does not return any results. I > enabled the debug for tools and below is the debug statements as seen on > the stdout. Any thoughts or inputs on this will be much appreciated. > > command used : > bin/kafka-consumer-offset-checker.sh --zookeeper localhost:2181 --group > test-consumer-group > or > ./kafka-consumer-offset-checker.sh --zookeeper > broker1:2181,broker2:2181,broker3:2181 --group test-consumer-group > > DEBUG Querying X.X.X.X:9092 to locate offset manager for > test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:23:55,090] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:23:55,091] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:23:58,093] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:23:58,102] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:23:58,103] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:24:01,107] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:24:01,115] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:24:01,116] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:24:04,119] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:24:04,124] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:24:04,126] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:24:04,993] DEBUG Got ping response for sessionid: > 0x14d33e7fbc80002 after 3ms (org.apache.zookeeper.ClientCnxn) > [2015-05-08 10:24:07,127] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:24:07,131] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:24:07,132] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:24:10,132] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:24:10,138] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:24:10,139] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > [2015-05-08 10:24:13,143] DEBUG Querying X.X.X.X:9092 to locate offset > manager for test-consumer-group. (kafka.client.ClientUtils$) > [2015-05-08 10:24:13,151] DEBUG Consumer metadata response: > ConsumerMetadataResponse(None,15,0) (kafka.client.ClientUtils$) > [2015-05-08 10:24:13,152] DEBUG Query to X.X.X.X:9092 to locate offset > manager for test-consumer-group failed - will retry in 3000 milliseconds. > (kafka.client.ClientUtils$) > > Thanks, > Meghana > -- -Regards, Mayuresh R. Gharat (862) 250-7125
