Support Questions

Find answers, ask questions, and share your expertise

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