Support Questions

Find answers, ask questions, and share your expertise
Announcements
Now Live: Explore expert insights and technical deep dives on the new Cloudera Community BlogsRead the Announcement

Ambari metrics is showing stopped kafka broker, can anyone please help

avatar
New Member

ERROR Exception emitting metrics (org.apache.hadoop.metrics2.sink.kafka.KafkaTimelineMetricsReporter)
java.lang.IllegalArgumentException: connectionString cannot be null or empty
at org.apache.ambari.metrics.sink.relocated.curator.shaded.com.google.common.base.Preconditions.checkArgument(Preconditions.java:122)
at org.apache.ambari.metrics.sink.relocated.curator.ensemble.fixed.FixedEnsembleProvider.<init>(FixedEnsembleProvider.java:55)
at org.apache.ambari.metrics.sink.relocated.curator.ensemble.fixed.FixedEnsembleProvider.<init>(FixedEnsembleProvider.java:43)
at org.apache.ambari.metrics.sink.relocated.curator.CuratorZookeeperClient.<init>(CuratorZookeeperClient.java:69)
at org.apache.hadoop.metrics2.sink.timeline.availability.MetricCollectorHAHelper.findLiveCollectorHostsFromZNode(MetricCollectorHAHelper.java:69)
at org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink.findPreferredCollectHost(AbstractTimelineMetricsSink.java:540)
at org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink.getCurrentCollectorHost(AbstractTimelineMetricsSink.java:286)
at org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink.emitMetrics(AbstractTimelineMetricsSink.java:327)
at org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink.emitMetrics(AbstractTimelineMetricsSink.java:307)
at org.apache.hadoop.metrics2.sink.kafka.KafkaTimelineMetricsReporter.access$200(KafkaTimelineMetricsReporter.java:58)
at org.apache.hadoop.metrics2.sink.kafka.KafkaTimelineMetricsReporter$TimelineScheduledReporter.report(KafkaTimelineMetricsReporter.java:334)
at org.apache.hadoop.metrics2.sink.kafka.ScheduledReporter.report(ScheduledReporter.java:185)
at org.apache.hadoop.metrics2.sink.kafka.ScheduledReporter$1.run(ScheduledReporter.java:137)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)

1 REPLY 1

avatar
Super Collaborator

@radha56 

 

We need some more details to check and investigate this issue further: 

 

1) Provide us the stdout and stderr you are getting while restarting broker from Ambari >> Kafka 

2)  Complete ERROR trace from the log file from failed broker node 

3) Alert/WARN you are getting in Ambari >> Kafka >> Status page 

 

Thank you.