Created
October 30, 2020 12:55
-
-
Save cristianonicolai/0e115c17e58a219f9db821d1b1d09b01 to your computer and use it in GitHub Desktop.
kogito travels
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2020-10-30 22:53:38,530 INFO [org.inf.HOTROD] (main) ISPN004021: Infinispan version: Infinispan 'Corona Extra' 11.0.4.Final | |
2020-10-30 22:53:38,682 INFO [org.kie.kog.ser.eve.imp.AbstractMessageConsumer] (main) Consumer for class org.acme.travels.VisaApplication started. | |
2020-10-30 22:53:38,695 INFO [org.apa.kaf.cli.con.KafkaConsumer] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] Subscribed to topic(s): visasresponses | |
2020-10-30 22:53:38,735 INFO [org.kie.kog.ser.eve.imp.AbstractMessageConsumer] (main) Consumer for class org.acme.travels.VisaApplication started. | |
2020-10-30 22:53:38,737 ERROR [io.sma.rea.mes.kafka] (main) SRMSG18217: Unable to read a record from Kafka topics '[visasresponses]': java.lang.IllegalStateException: This processor allows only a single Subscriber | |
at io.smallrye.mutiny.vertx.MultiReadStream.subscribe(MultiReadStream.java:62) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke.subscribe(MultiOnFailureInvoke.java:29) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnSubscribeCall.subscribe(MultiOnSubscribeCall.java:36) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiMapOp.subscribe(MultiMapOp.java:24) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke.subscribe(MultiOnItemInvoke.java:22) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke.subscribe(MultiOnFailureInvoke.java:29) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiMapOp.subscribe(MultiMapOp.java:24) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.groups.MultiSubscribe.with(MultiSubscribe.java:217) | |
at org.acme.travels.TravelsMessageConsumer_4.init(TravelsMessageConsumer_4.java:32) | |
at org.acme.travels.TravelsMessageConsumer_4_Bean.create(TravelsMessageConsumer_4_Bean.zig:403) | |
at org.acme.travels.TravelsMessageConsumer_4_Bean.create(TravelsMessageConsumer_4_Bean.zig:419) | |
at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:96) | |
at io.quarkus.arc.impl.AbstractSharedContext.access$000(AbstractSharedContext.java:14) | |
at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:29) | |
at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:26) | |
at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26) | |
at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69) | |
at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:26) | |
at org.acme.travels.TravelsMessageConsumer_4_ClientProxy.arc$delegate(TravelsMessageConsumer_4_ClientProxy.zig:92) | |
at org.acme.travels.TravelsMessageConsumer_4_ClientProxy.arc_contextualInstance(TravelsMessageConsumer_4_ClientProxy.zig:110) | |
at org.acme.travels.TravelsMessageConsumer_4_Observer_Synthetic_d70cd75bf32ab6598217b9a64a8473d65e248c05.notify(TravelsMessageConsumer_4_Observer_Synthetic_d70cd75bf32ab6598217b9a64a8473d65e248c05.zig:94) | |
at io.quarkus.arc.impl.EventImpl$Notifier.notifyObservers(EventImpl.java:282) | |
at io.quarkus.arc.impl.EventImpl$Notifier.notify(EventImpl.java:267) | |
at io.quarkus.arc.impl.EventImpl.fire(EventImpl.java:69) | |
at io.quarkus.arc.runtime.LifecycleEventRunner.fireStartupEvent(LifecycleEventRunner.java:23) | |
at io.quarkus.arc.runtime.ArcRecorder.handleLifecycleEvents(ArcRecorder.java:60) | |
at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy_0(LifecycleEventsBuildStep$startupEvent-858218658.zig:81) | |
at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy(LifecycleEventsBuildStep$startupEvent-858218658.zig:40) | |
at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:652) | |
at io.quarkus.runtime.Application.start(Application.java:90) | |
at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:93) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:62) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:38) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:104) | |
at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29) | |
java.lang.Exception: Missing onFailure/onError handler in the subscriber | |
at io.smallrye.mutiny.subscription.Subscribers.lambda$static$0(Subscribers.java:18) | |
at io.smallrye.mutiny.subscription.Subscribers$CallbackBasedSubscriber.onFailure(Subscribers.java:81) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.subscription.SafeSubscriber.onError(SafeSubscriber.java:138) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onFailure(MultiOperatorProcessor.java:55) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.subscription.SafeSubscriber.onError(SafeSubscriber.java:138) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.subscription.SafeSubscriber.onError(SafeSubscriber.java:129) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
2020-10-30 22:53:38,741 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] Error while fetching metadata with correlation id 2 : {visasresponses=LEADER_NOT_AVAILABLE} | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke$MultiOnFailureInvokeProcessor.onFailure(MultiOnFailureInvoke.java:49) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onFailure(MultiOperatorProcessor.java:55) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onFailure(MultiOperatorProcessor.java:55) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOperatorProcessor.onFailure(MultiOperatorProcessor.java:55) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.helpers.HalfSerializer.onError(HalfSerializer.java:56) | |
at io.smallrye.mutiny.helpers.StrictMultiSubscriber.onFailure(StrictMultiSubscriber.java:89) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke$MultiOnFailureInvokeProcessor.onFailure(MultiOnFailureInvoke.java:49) | |
2020-10-30 22:53:38,746 INFO [org.apa.kaf.cli.Metadata] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] Cluster ID: Ui16lExmS32IFkqfOmMlTQ | |
at io.smallrye.mutiny.subscription.MultiSubscriber.onError(MultiSubscriber.java:73) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.lambda$onError$2(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationSubscriber.onError(ContextPropagationMultiInterceptor.java:89) | |
at io.smallrye.mutiny.helpers.Subscriptions.fail(Subscriptions.java:68) | |
at io.smallrye.mutiny.helpers.Subscriptions.fail(Subscriptions.java:57) | |
at io.smallrye.mutiny.vertx.MultiReadStream.subscribe(MultiReadStream.java:62) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke.subscribe(MultiOnFailureInvoke.java:29) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnSubscribeCall.subscribe(MultiOnSubscribeCall.java:36) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiMapOp.subscribe(MultiMapOp.java:24) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnItemInvoke.subscribe(MultiOnItemInvoke.java:22) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
2020-10-30 22:53:38,747 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiOnFailureInvoke.subscribe(MultiOnFailureInvoke.java:29) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
2020-10-30 22:53:38,775 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] (Re-)joining group | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.operators.multi.MultiMapOp.subscribe(MultiMapOp.java:24) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:31) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.groups.MultiCreate$1.subscribe(MultiCreate.java:159) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti$1.run(ContextPropagationMultiInterceptor.java:57) | |
at io.smallrye.context.SmallRyeThreadContext.lambda$withContext$0(SmallRyeThreadContext.java:217) | |
at io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti.subscribe(ContextPropagationMultiInterceptor.java:51) | |
at io.smallrye.mutiny.operators.AbstractMulti.subscribe(AbstractMulti.java:24) | |
2020-10-30 22:53:38,805 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group | |
at io.smallrye.mutiny.groups.MultiSubscribe.withSubscriber(MultiSubscribe.java:69) | |
at io.smallrye.mutiny.groups.MultiSubscribe.with(MultiSubscribe.java:217) | |
at org.acme.travels.TravelsMessageConsumer_4.init(TravelsMessageConsumer_4.java:32) | |
at org.acme.travels.TravelsMessageConsumer_4_Bean.create(TravelsMessageConsumer_4_Bean.zig:403) | |
at org.acme.travels.TravelsMessageConsumer_4_Bean.create(TravelsMessageConsumer_4_Bean.zig:419) | |
at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:96) | |
at io.quarkus.arc.impl.AbstractSharedContext.access$000(AbstractSharedContext.java:14) | |
2020-10-30 22:53:38,811 INFO [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=consumer-de5f7da0-e8b5-4a20-a53d-cd8985f3dad2-1, groupId=de5f7da0-e8b5-4a20-a53d-cd8985f3dad2] (Re-)joining group | |
at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:29) | |
at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:26) | |
at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26) | |
at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69) | |
at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:26) | |
at org.acme.travels.TravelsMessageConsumer_4_ClientProxy.arc$delegate(TravelsMessageConsumer_4_ClientProxy.zig:92) | |
at org.acme.travels.TravelsMessageConsumer_4_ClientProxy.arc_contextualInstance(TravelsMessageConsumer_4_ClientProxy.zig:110) | |
at org.acme.travels.TravelsMessageConsumer_4_Observer_Synthetic_d70cd75bf32ab6598217b9a64a8473d65e248c05.notify(TravelsMessageConsumer_4_Observer_Synthetic_d70cd75bf32ab6598217b9a64a8473d65e248c05.zig:94) | |
at io.quarkus.arc.impl.EventImpl$Notifier.notifyObservers(EventImpl.java:282) | |
at io.quarkus.arc.impl.EventImpl$Notifier.notify(EventImpl.java:267) | |
at io.quarkus.arc.impl.EventImpl.fire(EventImpl.java:69) | |
at io.quarkus.arc.runtime.LifecycleEventRunner.fireStartupEvent(LifecycleEventRunner.java:23) | |
at io.quarkus.arc.runtime.ArcRecorder.handleLifecycleEvents(ArcRecorder.java:60) | |
at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy_0(LifecycleEventsBuildStep$startupEvent-858218658.zig:81) | |
at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy(LifecycleEventsBuildStep$startupEvent-858218658.zig:40) | |
at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:652) | |
at io.quarkus.runtime.Application.start(Application.java:90) | |
at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:93) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:62) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:38) | |
at io.quarkus.runtime.Quarkus.run(Quarkus.java:104) | |
at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29) | |
Caused by: io.smallrye.mutiny.CompositeException: Multiple exceptions caught: | |
[Exception 0] java.lang.IllegalStateException: This processor allows only a single Subscriber | |
[Exception 1] java.lang.NullPointerException: Subscription not set! | |
... 138 more | |
Suppressed: java.lang.NullPointerException: Subscription not set! | |
at io.smallrye.mutiny.subscription.SafeSubscriber.onError(SafeSubscriber.java:119) | |
... 137 more | |
Caused by: java.lang.IllegalStateException: This processor allows only a single Subscriber | |
... 85 more |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment