I upgraded one of my brokers to 0.10.0. I followed the upgrade guide and added these to my server.properties:
inter.broker.protocol.version=0.9.0.1 log.message.format.version=0.9.0.1 When checking the lag i get this error. [ac...@ekk001.scl ~]$ sudo /opt/kafka/kafka_2.11-0.10.0.0/bin/kafka-consumer-groups.sh --bootstrap-server=ekk001.scl:9092,ekk002.scl:9092 --new-consumer --describe --group fdm_indexers Error while executing consumer group command Request GROUP_COORDINATOR failed on brokers List(ekk001.scl:9092 (id: -1 rack: null), ekk002.scl:9092 (id: -2 rack: null)) java.lang.RuntimeException: Request GROUP_COORDINATOR failed on brokers List(ekk001.scl:9092 (id: -1 rack: null), ekk002.scl:9092 (id: -2 rack: null)) at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:67) at kafka.admin.AdminClient.findCoordinator(AdminClient.scala:72) at kafka.admin.AdminClient.describeGroup(AdminClient.scala:125) at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:147) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:315) at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:86) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:303) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:65) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) I happen to still have the 0.9.0.1 bits on disk so i ran that kafka-consumer-group.sh and that works just fine. [ac...@ekk001.scl ~]$ sudo /opt/kafka/kafka_2.11-0.9.0.1/bin/kafka-consumer-groups.sh --bootstrap-server=ekk001.scl:9092,ekk002.scl:9092 --new-consumer --describe --group fdm_indexers GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER fdm_indexers, freedom_logs, 1, 1778672075, 1778672075, 0, lsi016.scl_/10.x.92.156 fdm_indexers, freedom_logs, 5, 433366037, 433366037, 0, lsi099.scl_/10.x.92.160 fdm_indexers, freedom_logs, 3, 1778672009, 1778672009, 0, lsi018.scl_/10.x.92.158 fdm_indexers, freedom_logs, 2, 1778672066, 1778672066, 0, lsi017.scl_/10.x.92.157 fdm_indexers, freedom_logs, 0, 1778672030, 1778672030, 0, lsi015.scl_/10.x.92.155 fdm_indexers, freedom_logs, 4, 499098735, 499098735, 0, lsi019.scl_/10.x.92.159 I browsed through the release notes and couldn't isolate anything that would be related. Any one have idea why this is happening? -- Allen Michael Chan