Error in openwhisk/user-events container - Failed to construct kafka consumer
- Dominant language
- Scala
- Stars
- 6.8k
- Forks
- 1.2k
- Avg merge
- 2d 14h
- Merged PRs (30d)
- 2
Description
I am using openwhisk/user-events image to get openwhisk user events metrics but getting below error in logs :
[2020-04-28T12:01:52.585Z] [WARN] Failed to attach the instrumentation because the Kamon Bundle is not present on the classpath
[2020-04-28T12:01:55.876Z] [INFO] Started the Kamon StatsD reporter
[2020-04-28T12:02:00.082Z] [INFO] Slf4jLogger started
[2020-04-28T12:02:06.290Z] [WARN] Failed to attach the instrumentation because the Kamon Bundle is not present on the classpath
[2020-04-28T12:02:06.375Z] [INFO] The configuration was reloaded successfully.
[2020-04-28T12:02:06.383Z] [INFO] The configuration was reloaded successfully.
[2020-04-28T12:02:11.487Z] [INFO] [86d90] Starting. StageActor Actor[akka://events-actor-system/system/StreamSupervisor-0/$$a#-1600619777]
**[2020-04-28T12:02:14.481Z] [ERROR] Failed to construct kafka consumer**
akka.actor.ActorInitializationException: akka://events-actor-system/system/kafka-consumer-1: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:202)
at akka.actor.ActorCell.create(ActorCell.scala:696)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:547)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:569)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:293)
at akka.dispatch.Mailbox.run(Mailbox.scala:228)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:820)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:631)
at akka.kafka.ConsumerSettings$.createKafkaConsumer(ConsumerSettings.scala:182)
at akka.kafka.ConsumerSettings$.$anonfun$apply$3(ConsumerSettings.scala:98)
at akka.kafka.ConsumerSettings$$$Lambda$628/00000000DA0A1690.apply(Unknown Source)
at akka.kafka.internal.KafkaConsumerActor.akka$kafka$internal$KafkaConsumerActor$$applySettings(KafkaConsumerActor.scala:449)
at akka.kafka.internal.KafkaConsumerActor.preStart(KafkaConsumerActor.scala:426)
at akka.actor.Actor.aroundPreStart(Actor.scala:550)
at akka.actor.Actor.aroundPreStart$(Actor.scala:550)
at akka.kafka.internal.KafkaConsumerActor.aroundPreStart(KafkaConsumerActor.scala:205)
at akka.actor.ActorCell.create(ActorCell.scala:676)
... 7 common frames omitted
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:88)
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:47)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:735)
... 17 common frames omitted
[2020-04-28T12:02:14.482Z] [INFO] Message [akka.kafka.internal.KafkaConsumerActor$Internal$Subscribe] from Actor[akka://events-actor-system/system/StreamSupervisor-0/$$a#-1600619777] to Actor[akka://events-actor-system/system/kafka-consumer-1#-1989616186] was not delivered. [1] dead letters encountered. If this is not an expected behavior, then [Actor[akka://events-actor-system/system/kafka-consumer-1#-1989616186]] may have terminated unexpectedly, This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[2020-04-28T12:02:14.483Z] [INFO] Message [akka.kafka.internal.KafkaConsumerActor$Internal$StopFromStage] from Actor[akka://events-actor-system/system/StreamSupervisor-0/$$a#-1600619777] to Actor[akka://events-actor-system/system/kafka-consumer-1#-1989616186] was not delivered. [2] dead letters encountered. If this is not an expected behavior, then [Actor[akka://events-actor-system/system/kafka-consumer-1#-1989616186]] may have terminated unexpectedly, This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[2020-04-28T12:02:21.294Z] [ERROR] kafka.consumer:type=consumer-fetch-manager-metrics,client-id=event-consumer
javax.management.InstanceNotFoundException: kafka.consumer:type=consumer-fetch-manager-metrics,client-id=event-consumer
at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1083)
at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:637)
at java.management/com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:678)
at org.apache.openwhisk.core.monitoring.metrics.EventConsumer$.consumerLag(EventConsumer.scala:157)
at org.apache.openwhisk.core.monitoring.metrics.EventConsumer.$anonfun$lagRecorder$1(EventConsumer.scala:101)
at org.apache.openwhisk.core.monitoring.metrics.EventConsumer$$Lambda$657/00000000DA230530.apply$mcV$sp(Unknown Source)
at akka.actor.Scheduler$$anon$2.run(Scheduler.scala:105)
at akka.actor.LightArrayRevolverScheduler$$anon$1$$anon$2.run(LightArrayRevolverScheduler.scala:104)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:49)
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
## Environment details:
Local environment, using docker-compose
## Steps to reproduce the issue:
1. Make quick-start
2. Make docker-build
3. docker-compose up -->
version: '3'
networks:
openwhisk_default:
external: true
services:
openwhisk-monitor:
container_name: openwhisk-monitor
image: openwhisk/user-events:nightly
restart: "always"
ports:
- "9085:9095"
networks:
- openwhisk_default
## Provide the expected results and outputs:
```
It should run without any error
```
## Provide the actual results and outputs:
```
Failed to construct kafka consumer
```
Contributor guide
Assessment
This issue has not been assessed yet.