You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@openwhisk.apache.org by GitBox <gi...@apache.org> on 2020/04/28 13:43:49 UTC
[GitHub] [openwhisk] pankaj-dahiya opened a new issue #4893: Error in openwhisk/user-events container - Failed to construct kafka consumer
pankaj-dahiya opened a new issue #4893:
URL: https://github.com/apache/openwhisk/issues/4893
<!--
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.<init>(KafkaConsumer.java:820)
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(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.<init>(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
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org