[
https://issues.apache.org/jira/browse/KAFKA-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118474#comment-15118474
]
linbao111 commented on KAFKA-3151:
----------------------------------
sasl is enabled on my test cluster,following tools work fine on the cluster
su kafka
export
KAFKA_JVM_PERFORMANCE_OPTS="-Djava.security.auth.login.config=/opt/alalei/kafka_2.10-0.9.0.1-SNAPSHOT/config/kafka_server_jaas.conf
-Djava.security.krb5.conf=/etc/krb5.conf"
#生产者
./bin/kafka-console-producer.sh --broker-list slave16.otocyon.com:9092 --topic
alalei_2 --producer.config config/producer.properties
#消费者
./bin/kafka-console-consumer.sh --new-consumer --bootstrap-server slave16:9092
--zookeeper slave1.otocyon.com:2181 --topic alalei_2 --consumer.conf
config/consumer.properties --from-beginning
> 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)
