Skip to content

Instantly share code, notes, and snippets.

@cristianonicolai

cristianonicolai/travels.log

Created October 30, 2020 12:55
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cristianonicolai/0e115c17e58a219f9db821d1b1d09b01 to your computer and use it in GitHub Desktop.
Save cristianonicolai/0e115c17e58a219f9db821d1b1d09b01 to your computer and use it in GitHub Desktop.
Download ZIP
kogito travels
Raw
travels.log
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