Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

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

avatar
New Contributor

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
Expert Contributor

@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.