Cloudera Community
sauravsuman689
user rank
New Contributor

Kafka consumer groups are not getting listed and ...

by New Contributor in Support Questions
‎08-14-2019 03:01 PM
‎08-14-2019 03:01 PM
Hi, I am using kafka version 0.10.1 on HDP 2.6 with kerberos enabled. When I am trying to get the list of consumer groups and describe group with below commands I am getting error message. Please advise. [kafka@XXX ~]$ /usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --bootstrap-server xxxx:6667,xxxx:6667,xxxx:6667 --list --command-config /tmp/grouprop.properties [2019-08-13 02:40:56,791] WARN TGT renewal thread has been interrupted and will exit. (org.apache.kafka.common.security.kerberos.KerberosLogin) [kafka@XXX ]$ /usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server xxxx:6667 --describe --group uat_customer --command-config /tmp/grouprop.properties Error while executing consumer group command Failed to send request after 5000 ms. org.apache.kafka.common.errors.TimeoutException: Failed to send request after 5000 ms. [2019-08-14 09:57:39,346] WARN TGT renewal thread has been interrupted and will exit. (org.apache.kafka.common.security.kerberos.KerberosLogin) [kafka@XXX]$ /usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server xxxx:6667 --list --command-config /tmp/grouprop.properties Error while executing consumer group command Request METADATA failed on brokers List(xxx:6667 (id: -1 rack: null)) java.lang.RuntimeException: Request METADATA failed on brokers List(xxxx:6667 (id: -1 rack: null)) at kafka.admin.AdminClient.sendAnyNode(AdminClient.scala:67) at kafka.admin.AdminClient.findAllBrokers(AdminClient.scala:87) at kafka.admin.AdminClient.listAllGroups(AdminClient.scala:96) at kafka.admin.AdminClient.listAllGroupsFlattened(AdminClient.scala:117) at kafka.admin.AdminClient.listAllConsumerGroupsFlattened(AdminClient.scala:121) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.list(ConsumerGroupCommand.scala:304) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:66) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) [2019-08-14 10:03:05,877] WARN TGT renewal thread has been interrupted and will exit. (org.apache.kafka.common.security.kerberos.KerberosLogin) cat /tmp/grouprop.properties security.protocol=PLAINTEXTSASL ... View more
Labels:

Re: Alert Configuration on Ambari

by New Contributor in Support Questions
‎01-03-2017 12:02 PM
‎01-03-2017 12:02 PM
@Neeraj Sabharwal I tried changing the description from the ambari UI but it didn't work. Then I tried modifying the alert_disk_space.py script with PERCENT_USED_WARNING_DEFAULT = 60 and restarted my ambari server. but still I can't see the changes from the UI. And my alert which got generated for 50% utilization still exist. Please advise. ... View more

Re: Alert Configuration on Ambari

by New Contributor in Support Questions
‎01-03-2017 09:43 AM
‎01-03-2017 09:43 AM
I tried changing the description from the ambari UI but it didn't work. Then I tried modifying the alert_disk_space.py script with PERCENT_USED_WARNING_DEFAULT = 60 and restarted my ambari server. but still I can't see the changes from the UI. And my alert which got generated for 50% utilization still exist. Please advise. ... View more
Contact Me
Online
Offline
Last Visited
‎08-14-2019 03:01 PM
Community Statistics
Member Since ‎01-03-2017 09:39 AM
Last Visited ‎08-14-2019 03:01 PM
Posts 3