[jira] [Created] (KAFKA-3151) kafka-consumer-groups.sh fail with sasl enabled

[linbao111 (JIRA)]

linbao111 created KAFKA-3151:
--------------------------------

             Summary: kafka-consumer-groups.sh fail with sasl enabled 
                 Key: KAFKA-3151
                 URL: https://issues.apache.org/jira/browse/KAFKA-3151
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 0.9.0.1
         Environment: redhat as6.5
            Reporter: linbao111


./bin/kafka-consumer-groups.sh --new-consumer  --bootstrap-server 
slave1.otocyon.com:9092 --list
Error while executing consumer group command Request METADATA failed on brokers 
List(Node(-1, slave1.otocyon.com, 9092))
java.lang.RuntimeException: Request METADATA failed on brokers List(Node(-1, 
slave1.otocyon.com, 9092))
        at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:73)
        at kafka.admin.AdminClient.findAllBrokers(AdminClient.scala:93)
        at kafka.admin.AdminClient.listAllGroups(AdminClient.scala:101)
        at kafka.admin.AdminClient.listAllGroupsFlattened(AdminClient.scala:122)
        at 
kafka.admin.AdminClient.listAllConsumerGroupsFlattened(AdminClient.scala:126)
        at 
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.list(ConsumerGroupCommand.scala:310)
        at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:61)
        at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)

same error for:
bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand  --bootstrap-server 
slave16:9092,app:9092 --describe --group test-consumer-group  --new-consumer
Error while executing consumer group command Request GROUP_COORDINATOR failed 
on brokers List(Node(-1, slave16, 9092), Node(-2, app, 9092))
java.lang.RuntimeException: Request GROUP_COORDINATOR failed on brokers 
List(Node(-1, slave16, 9092), Node(-2, app, 9092))
        at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:73)
        at kafka.admin.AdminClient.findCoordinator(AdminClient.scala:78)
        at kafka.admin.AdminClient.describeGroup(AdminClient.scala:130)
        at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:152)
        at 
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:314)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:84)
        at 
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:302)
        at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:63)
        at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)