EventTestKit debugging

gistfile1.txt

2023-11-30 13:00:39,137 INFO  proxy-logs - STDOUT: 21:00:39.134 INFO  k.proxy.eventing.ProjectionDaemon$ - Projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject] starting. Process index [0] of total [1] instances.
2023-11-30 13:00:39,137 INFO  proxy-logs - STDOUT: 21:00:39.134 INFO  k.p.e.EventSourcedEntityEventing - Creating projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject / lightspark-wallet-0-1023] for entity type [lightspark-wallet]
2023-11-30 13:00:39,137 INFO  proxy-logs - STDOUT: 21:00:39.135 INFO  k.proxy.eventing.ProjectionDaemon$ - Starting projection [ProjectionId(eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject, lightspark-wallet-0-1023)]
2023-11-30 13:00:42,928 INFO  proxy-logs - STDOUT: 21:00:41.855 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletCreated,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletCreated),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:42,928 INFO  proxy-logs - STDOUT: 21:00:41.855 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletDeleted,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletDeleted),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:42,928 INFO  proxy-logs - STDOUT: 21:00:41.855 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.Ignore,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/Ignore),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:42,928 INFO  proxy-logs - STDOUT: 21:00:41.855 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.GetWallets,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/GetWallets),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:42,931 INFO  proxy-logs - STDOUT: 21:00:42.670 INFO  kalix.proxy.SchemaSingleton - Execute DDL: create view [WalletsBySubject]
2023-11-30 13:00:42,931 INFO  proxy-logs - STDOUT: 21:00:42.672 INFO  kalix.proxy.views.ViewSupportFactory - Successfully created view table for view [WalletsBySubject]: [view_85d9deec200ec77a8f0c9]
2023-11-30 13:00:43,029 INFO  proxy-logs - STDOUT: 21:00:43.025 INFO  kalix.proxy.eventing.EventingManager - Eventing Manager StartConsumer for component [xyz.instantpay.grpc.lightspark.WalletsBySubject], event source options: [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], topicSupport: [Some(kalix.proxy.eventing.GrpcEventingSupport@4383e16e)], eventSourcedEntitySupport: [Some(kalix.proxy.eventing.EventSourcedEntityEventing@5148c407)], valueEntitySupport: [Some(kalix.proxy.eventing.ValueEntityEventing@4a2c1d26)]
2023-11-30 13:00:43,862 INFO  proxy-logs - STDOUT: 21:00:43.860 INFO  k.proxy.eventing.ProjectionDaemon$ - Projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject] starting. Process index [0] of total [1] instances.
2023-11-30 13:00:43,862 INFO  proxy-logs - STDOUT: 21:00:43.861 INFO  k.p.e.EventSourcedEntityEventing - Creating projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject / lightspark-wallet-0-1023] for entity type [lightspark-wallet]
2023-11-30 13:00:43,992 INFO  proxy-logs - STDOUT: 21:00:43.986 INFO  k.proxy.eventing.ProjectionDaemon$ - Starting projection [ProjectionId(eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject, lightspark-wallet-0-1023)]
2023-11-30 13:00:48,281 INFO  proxy-logs - STDOUT: 21:00:47.146 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletCreated,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletCreated),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:48,281 INFO  proxy-logs - STDOUT: 21:00:47.146 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletDeleted,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletDeleted)
2023-11-30 13:00:48,281 INFO  proxy-logs - STDOUT: ,*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:48,281 INFO  proxy-logs - STDOUT: 21:00:47.146 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.Ignore,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/Ignore),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:48,281 INFO  proxy-logs - STDOUT: 21:00:47.146 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.GetWallets,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/GetWallets),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:48,287 INFO  proxy-logs - STDOUT: 21:00:48.023 INFO  kalix.proxy.SchemaSingleton - Execute DDL: create view [WalletsBySubject]
2023-11-30 13:00:48,287 INFO  proxy-logs - STDOUT: 21:00:48.024 INFO  kalix.proxy.views.ViewSupportFactory - Successfully created view table for view [WalletsBySubject]: [view_85d9deec200ec77a8f0c9]
2023-11-30 13:00:48,565 INFO  proxy-logs - STDOUT: 21:00:48.388 INFO  kalix.proxy.eventing.EventingManager - Eventing Manager StartConsumer for component [xyz.instantpay.grpc.lightspark.WalletsBySubject], event source options: [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], topicSupport: [Some(kalix.proxy.eventing.GrpcEventingSupport@1777c43c)], eventSourcedEntitySupport: [Some(kalix.proxy.eventing.EventSourcedEntityEventing@30740960)], valueEntitySupport: [Some(kalix.proxy.eventing.ValueEntityEventing@3e3fc5e1)]
2023-11-30 13:00:49,002 INFO  proxy-logs - STDOUT: 21:00:48.999 INFO  k.proxy.eventing.ProjectionDaemon$ - Projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject] starting. Process index [0] of total [1] instances.
2023-11-30 13:00:49,022 INFO  proxy-logs - STDOUT: 21:00:48.999 INFO  k.p.e.EventSourcedEntityEventing - Creating projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject / lightspark-wallet-0-1023] for entity type [lightspark-wallet]
2023-11-30 13:00:49,022 INFO  proxy-logs - STDOUT: 21:00:49.000 INFO  k.proxy.eventing.ProjectionDaemon$ - Starting projection [ProjectionId(eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject, lightspark-wallet-0-1023)]
2023-11-30 13:00:52,712 INFO  proxy-logs - STDOUT: 21:00:51.542 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletCreated,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletCreated),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:52,713 INFO  proxy-logs - STDOUT: 21:00:51.542 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletDeleted,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletDeleted),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:52,713 INFO  proxy-logs - STDOUT: 21:00:51.542 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.li
2023-11-30 13:00:52,713 INFO  proxy-logs - STDOUT: ghtspark.WalletsBySubject.Ignore,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/Ignore),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:52,713 INFO  proxy-logs - STDOUT: 21:00:51.543 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.GetWallets,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/GetWallets),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:00:52,723 INFO  proxy-logs - STDOUT: 21:00:52.408 INFO  kalix.proxy.SchemaSingleton - Execute DDL: create view [WalletsBySubject]
2023-11-30 13:00:52,723 INFO  proxy-logs - STDOUT: 21:00:52.410 INFO  kalix.proxy.views.ViewSupportFactory - Successfully created view table for view [WalletsBySubject]: [view_85d9deec200ec77a8f0c9]
2023-11-30 13:00:52,808 INFO  proxy-logs - STDOUT: 21:00:52.806 INFO  kalix.proxy.eventing.EventingManager - Eventing Manager StartConsumer for component [xyz.instantpay.grpc.lightspark.WalletsBySubject], event source options: [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], topicSupport: [Some(kalix.proxy.eventing.GrpcEventingSupport@179cb585)], eventSourcedEntitySupport: [Some(kalix.proxy.eventing.EventSourcedEntityEventing@65e19670)], valueEntitySupport: [Some(kalix.proxy.eventing.ValueEntityEventing@4a77d546)]
2023-11-30 13:00:53,234 INFO  proxy-logs - STDOUT: 21:00:53.233 INFO  k.proxy.eventing.ProjectionDaemon$ - Projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject] starting. Process index [0] of total [1] instances.
2023-11-30 13:00:53,235 INFO  proxy-logs - STDOUT: 21:00:53.234 INFO  k.p.e.EventSourcedEntityEventing - Creating projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject / lightspark-wallet-0-1023] for entity type [lightspark-wallet]
2023-11-30 13:00:53,235 INFO  proxy-logs - STDOUT: 21:00:53.234 INFO  k.proxy.eventing.ProjectionDaemon$ - Starting projection [ProjectionId(eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject, lightspark-wallet-0-1023)]
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 21:01:13.991 ERROR k.proxy.eventing.GrpcEventingSupport - Flow for source [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], failed
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at io.grpc.Status.asRuntimeException(Status.java:537)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.onCallClosed(AkkaNettyGrpcClientGraphStage.scala:164)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1(AkkaNettyGrpcClientGraphStage.scala:70)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1$adapted(AkkaNettyGrpcClientGraphStage.scala:66)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:482)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:517)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:625)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:800)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:818)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:716)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
2023-11-30 13:01:14,189 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 21:01:14.490 ERROR k.proxy.eventing.GrpcEventingSupport - Flow for source [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], failed
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at io.grpc.Status.asRuntimeException(Status.java:537)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.onCallClosed(AkkaNettyGrpcClientGraphStage.scala:164)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1(AkkaNettyGrpcClientGraphStage.scala:70)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1$adapted(AkkaNettyGrpcClientGraphStage.scala:66)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:482)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:517)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:625)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:800)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:818)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:716)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
2023-11-30 13:01:14,652 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 21:01:14.532 ERROR k.proxy.eventing.GrpcEventingSupport - Flow for source [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], failed
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at io.grpc.Status.asRuntimeException(Status.java:537)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.onCallClosed(AkkaNettyGrpcClientGraphStage.scala:164)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1(AkkaNettyGrpcClientGraphStage.scala:70)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1$adapted(AkkaNettyGrpcClientGraphStage.scala:66)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:482)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:517)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:625)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:800)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:818)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:716)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
2023-11-30 13:01:14,702 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
2023-11-30 13:01:15,008 INFO  proxy-logs - STDOUT: 21:01:14.854 ERROR k.proxy.eventing.GrpcEventingSupport - Flow for source [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], failed
2023-11-30 13:01:15,008 INFO  proxy-logs - STDOUT: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
2023-11-30 13:01:15,008 INFO  proxy-logs - STDOUT: 	at io.grpc.Status.asRuntimeException(Status.java:537)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.onCallClosed(AkkaNettyGrpcClientGraphStage.scala:164)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1(AkkaNettyGrpcClientGraphStage.scala:70)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.grpc.internal.AkkaNettyGrpcClientGraphStage$$anon$1.$anonfun$callback$1$adapted(AkkaNettyGrpcClientGraphStage.scala:66)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:482)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:517)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:625)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:800)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:818)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:716)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
2023-11-30 13:01:15,009 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
2023-11-30 13:01:16,723 INFO  proxy-logs - STDOUT: 21:01:15.477 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletCreated,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletCreated),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:01:16,723 INFO  proxy-logs - STDOUT: 21:01:15.477 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.OnWalletDeleted,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/OnWalletDeleted),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:01:16,723 INFO  proxy-logs - STDOUT: 21:01:15.478 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.Ignore,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/Ignore),*,,List(),Unknown
2023-11-30 13:01:16,723 INFO  proxy-logs - STDOUT: FieldSet(Map()))]
2023-11-30 13:01:16,723 INFO  proxy-logs - STDOUT: 21:01:15.478 INFO  k.p.h.HttpEndpointMethodDefinition - Using generated HTTP API endpoint using [HttpRule(xyz.instantpay.grpc.lightspark.WalletsBySubject.GetWallets,Post(/xyz.instantpay.grpc.lightspark.WalletsBySubject/GetWallets),*,,List(),UnknownFieldSet(Map()))]
2023-11-30 13:01:16,727 INFO  proxy-logs - STDOUT: 21:01:16.373 INFO  kalix.proxy.SchemaSingleton - Execute DDL: create view [WalletsBySubject]
2023-11-30 13:01:16,727 INFO  proxy-logs - STDOUT: 21:01:16.374 INFO  kalix.proxy.views.ViewSupportFactory - Successfully created view table for view [WalletsBySubject]: [view_85d9deec200ec77a8f0c9]
2023-11-30 13:01:16,832 INFO  proxy-logs - STDOUT: 21:01:16.673 INFO  kalix.proxy.eventing.EventingManager - Eventing Manager StartConsumer for component [xyz.instantpay.grpc.lightspark.WalletsBySubject], event source options: [EventSource(WalletsBySubject,EventSourcedEntity(lightspark-wallet),false,None,None,UnknownFieldSet(Map()))], topicSupport: [Some(kalix.proxy.eventing.GrpcEventingSupport@4770b738)], eventSourcedEntitySupport: [Some(kalix.proxy.eventing.EventSourcedEntityEventing@41cf2f1a)], valueEntitySupport: [Some(kalix.proxy.eventing.ValueEntityEventing@5d9aa839)]
2023-11-30 13:01:18,373 INFO  proxy-logs - STDOUT: 21:01:18.218 INFO  k.proxy.eventing.ProjectionDaemon$ - Projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject] starting. Process index [0] of total [1] instances.
2023-11-30 13:01:18,381 INFO  proxy-logs - STDOUT: 21:01:18.227 INFO  k.p.e.EventSourcedEntityEventing - Creating projection [eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject / lightspark-wallet-0-1023] for entity type [lightspark-wallet]
2023-11-30 13:01:18,383 INFO  proxy-logs - STDOUT: 21:01:18.229 INFO  k.proxy.eventing.ProjectionDaemon$ - Starting projection [ProjectionId(eventSourcedProjection-lightspark-wallet-xyz.instantpay.grpc.lightspark.WalletsBySubject-WalletsBySubject, lightspark-wallet-0-1023)]
2023-11-30 13:01:19,972 ERROR akka.actor.OneForOneStrategy - null
akka.stream.SubscriptionWithCancelException$NoMoreElementsNeeded$: null


Future timed out after [5 seconds]
java.util.concurrent.TimeoutException: Future timed out after [5 seconds]
	at scala.concurrent.impl.Promise$DefaultPromise.tryAwait0(Promise.scala:248)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:261)
	at scala.concurrent.Await$.$anonfun$result$1(package.scala:201)
	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:62)
	at scala.concurrent.Await$.result(package.scala:124)
	at kalix.javasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:308)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:49)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:55)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3$adapted(WalletsBySubjectViewSpec.scala:21)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.<init>(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.$anonfun$new$2(WalletsBySubjectViewSpec.scala:19)
	at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
	at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
	at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
	at org.scalatest.Transformer.apply(Transformer.scala:22)
	at org.scalatest.Transformer.apply(Transformer.scala:20)
	at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
	at org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
	at org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.xyz$instantpay$grpc$KalixIntegrationKit$$super$withFixture(WalletsBySubjectViewSpec.scala:10)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture(KalixIntegrationKit.scala:28)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture$(KalixIntegrationKit.scala:26)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.withFixture(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250)
	at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232)
	at org.scalatest.wordspec.AnyWordSpec.runTest(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
	at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308)
	at org.scalatest.wordspec.AnyWordSpec.runTests(AnyWordSpec.scala:1880)
	at org.scalatest.Suite.run(Suite.scala:1114)
	at org.scalatest.Suite.run$(Suite.scala:1096)
	at org.scalatest.wordspec.AnyWordSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$run$1(AnyWordSpecLike.scala:1354)
	at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
	at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1354)
	at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:1352)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.org$scalatest$BeforeAndAfterAll$$super$run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
	at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
	at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:47)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13(Runner.scala:1321)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13$adapted(Runner.scala:1315)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:1315)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24(Runner.scala:992)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24$adapted(Runner.scala:970)
	at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:1481)
	at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:970)
	at org.scalatest.tools.Runner$.run(Runner.scala:798)
	at org.scalatest.tools.Runner.run(Runner.scala)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2or3(ScalaTestRunner.java:43)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:26)


# From a different run

2023-11-30 13:41:34,622 INFO  🐳 [gcr.io/kalix-public/kalix-proxy:1.1.23] - Container gcr.io/kalix-public/kalix-proxy:1.1.23 is starting: 7f28be490aa9120397692bd1d52526fe690e43984e56377ad5dfbdbe887de638
2023-11-30 13:41:38,798 INFO  kalix.javasdk.impl.DiscoveryImpl - Received discovery call from [kalix-proxy-core 1.1.23] at [localhost]:[9000] supporting Kalix protocol 1.1
2023-11-30 13:41:43,710 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
2023-11-30 13:41:43,716 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
2023-11-30 13:41:43,717 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
[...]
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
2023-11-30 13:42:08,696 INFO  proxy-logs - STDOUT: 21:42:06.805 WARN  akka.cluster.ClusterHeartbeat - Cluster Node [akka://kalix-proxy@172.17.0.19:25520] - Scheduled sending of heartbeat was delayed. Previous heartbeat was sent [2162] ms ago, expected interval is [1000] ms. This may cause failure detection to mark members as unreachable. The reason can be thread starvation, CPU overload, or GC.
2023-11-30 13:42:09,816 INFO  proxy-logs - STDOUT: 21:42:07.791 WARN  akka.cluster.ClusterHeartbeat - Cluster Node [akka://kalix-proxy@172.17.0.19:25520] - Scheduled sending of heartbeat was delayed. Previous heartbeat was sent [24711] ms ago, expected interval is [1000] ms. This may cause failure detection to mark members as unreachable. The reason can be thread starvation, CPU overload, or GC.
[...]
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 21:42:25.984 WARN  a.s.s.RestartWithBackoffSource - Restarting stream due to failure [1]: io.r2dbc.spi.R2dbcTimeoutException: Connection acquisition timed out after 5000ms
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: io.r2dbc.spi.R2dbcTimeoutException: Connection acquisition timed out after 5000ms
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at io.r2dbc.pool.ConnectionPool.lambda$null$11(ConnectionPool.java:168)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.Mono.lambda$onErrorMap$27(Mono.java:3769)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.Mono.lambda$onErrorResume$29(Mono.java:3859)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:295)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:280)
2023-11-30 13:42:26,474 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:419)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:271)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:286)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	at java.base/java.lang.Thread.run(Unknown Source)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: Caused by: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 5000ms in 'Connection acquisition from [H2ConnectionFactory{clientFactory=MonoSupplier}]' (and no fallback has been configured)
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 	... 13 more
2023-11-30 13:42:26,475 INFO  proxy-logs - STDOUT: 
[...]

2023-11-30 13:23:41,387 ERROR akka.actor.OneForOneStrategy - null
akka.stream.SubscriptionWithCancelException$NoMoreElementsNeeded$: null
2023-11-30 13:23:43,512 INFO  proxy-logs - STDOUT: 21:23:41.350 WARN  akka.cluster.ClusterHeartbeat - Cluster Node [akka://kalix-proxy@172.17.0.4:25520] - Scheduled sending of heartbeat was delayed. Previous heartbeat was sent [2771] ms ago, expected interval is [1000] ms. This may cause failure detection to mark members as unreachable. The reason can be thread starvation, CPU overload, or GC.
2023-11-30 13:23:43,678 INFO  proxy-logs - STDOUT: 21:23:41.597 WARN  akka.cluster.ClusterHeartbeat - Cluster Node [akka://kalix-proxy@172.17.0.20:25520] - Scheduled sending of heartbeat was delayed. Previous heartbeat was sent [2306] ms ago, expected interval is [1000] ms. This may cause failure detection to mark members as unreachable. The reason can be thread starvation, CPU overload, or GC.
2023-11-30 13:23:43,821 INFO  proxy-logs - STDOUT: 21:23:41.738 WARN  akka.cluster.ClusterHeartbeat - Cluster Node [akka://kalix-proxy@172.17.0.14:25520] - Scheduled sending of heartbeat was delayed. Previous heartbeat was sent [2009] ms ago, expected interval is [1000] ms. This may cause failure detection to mark members as unreachable. The reason can be thread starvation, CPU overload, or GC.


Future timed out after [5 seconds]
java.util.concurrent.TimeoutException: Future timed out after [5 seconds]
	at scala.concurrent.impl.Promise$DefaultPromise.tryAwait0(Promise.scala:248)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:261)
	at scala.concurrent.Await$.$anonfun$result$1(package.scala:201)
	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:62)
	at scala.concurrent.Await$.result(package.scala:124)
	at kalix.javasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:308)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:49)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:55)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3$adapted(WalletsBySubjectViewSpec.scala:21)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.<init>(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.$anonfun$new$2(WalletsBySubjectViewSpec.scala:19)
	at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
	at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
	at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
	at org.scalatest.Transformer.apply(Transformer.scala:22)
	at org.scalatest.Transformer.apply(Transformer.scala:20)
	at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
	at org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
	at org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.xyz$instantpay$grpc$KalixIntegrationKit$$super$withFixture(WalletsBySubjectViewSpec.scala:10)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture(KalixIntegrationKit.scala:28)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture$(KalixIntegrationKit.scala:26)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.withFixture(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250)
	at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232)
	at org.scalatest.wordspec.AnyWordSpec.runTest(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
	at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308)
	at org.scalatest.wordspec.AnyWordSpec.runTests(AnyWordSpec.scala:1880)
	at org.scalatest.Suite.run(Suite.scala:1114)
	at org.scalatest.Suite.run$(Suite.scala:1096)
	at org.scalatest.wordspec.AnyWordSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$run$1(AnyWordSpecLike.scala:1354)
	at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
	at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1354)
	at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:1352)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.org$scalatest$BeforeAndAfterAll$$super$run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
	at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
	at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:47)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13(Runner.scala:1321)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13$adapted(Runner.scala:1315)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:1315)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24(Runner.scala:992)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24$adapted(Runner.scala:970)
	at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:1481)
	at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:970)
	at org.scalatest.tools.Runner$.run(Runner.scala:798)
	at org.scalatest.tools.Runner.run(Runner.scala)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2or3(ScalaTestRunner.java:43)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:26)

# kalix.javasdk.testkit

2023-12-01 09:23:36,793 INFO  kalix.javasdk.testkit.KalixTestKit - Eventing TestKit booting up on port: 52515
2023-12-01 09:23:40,575 INFO  kalix.javasdk.testkit.KalixTestKit - Eventing TestKit booting up on port: 52522
2023-12-01 09:23:45,752 INFO  kalix.javasdk.testkit.KalixTestKit - Eventing TestKit booting up on port: 52529
2023-12-01 09:23:50,344 INFO  kalix.javasdk.testkit.KalixTestKit - Eventing TestKit booting up on port: 52536
2023-12-01 09:24:02,562 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
2023-12-01 09:24:02,559 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
[...]
2023-12-01 09:24:14,017 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
2023-12-01 09:24:14,017 ERROR kalix.javasdk.testkit.impl.EventingTestServiceImpl - runSource in failed
akka.http.impl.engine.HttpIdleTimeoutException: HTTP idle-timeout encountered, no bytes passed in the last 60 seconds. This is configurable by akka.http.[server|client].idle-timeout.
[...]
2023-12-01 09:24:40,527 ERROR akka.actor.OneForOneStrategy - null
akka.stream.SubscriptionWithCancelException$NoMoreElementsNeeded$: null


Future timed out after [5 seconds]
java.util.concurrent.TimeoutException: Future timed out after [5 seconds]
	at scala.concurrent.impl.Promise$DefaultPromise.tryAwait0(Promise.scala:248)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:261)
	at scala.concurrent.Await$.$anonfun$result$1(package.scala:201)
	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:62)
	at scala.concurrent.Await$.result(package.scala:124)
	at kalix.javasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:308)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:49)
	at kalix.scalasdk.testkit.impl.IncomingMessagesImpl.publish(EventingTestKitImpl.scala:55)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.$anonfun$new$3$adapted(WalletsBySubjectViewSpec.scala:21)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec$$anon$1.<init>(WalletsBySubjectViewSpec.scala:21)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.$anonfun$new$2(WalletsBySubjectViewSpec.scala:19)
	at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
	at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
	at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
	at org.scalatest.Transformer.apply(Transformer.scala:22)
	at org.scalatest.Transformer.apply(Transformer.scala:20)
	at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
	at org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
	at org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.xyz$instantpay$grpc$KalixIntegrationKit$$super$withFixture(WalletsBySubjectViewSpec.scala:10)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture(KalixIntegrationKit.scala:28)
	at xyz.instantpay.grpc.KalixIntegrationKit.withFixture$(KalixIntegrationKit.scala:26)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.withFixture(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250)
	at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250)
	at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232)
	at org.scalatest.wordspec.AnyWordSpec.runTest(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
	at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
	at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
	at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309)
	at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308)
	at org.scalatest.wordspec.AnyWordSpec.runTests(AnyWordSpec.scala:1880)
	at org.scalatest.Suite.run(Suite.scala:1114)
	at org.scalatest.Suite.run$(Suite.scala:1096)
	at org.scalatest.wordspec.AnyWordSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(AnyWordSpec.scala:1880)
	at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$run$1(AnyWordSpecLike.scala:1354)
	at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
	at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1354)
	at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:1352)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.org$scalatest$BeforeAndAfterAll$$super$run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
	at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
	at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
	at xyz.instantpay.grpc.lightspark.WalletsBySubjectViewSpec.run(WalletsBySubjectViewSpec.scala:10)
	at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:47)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13(Runner.scala:1321)
	at org.scalatest.tools.Runner$.$anonfun$doRunRunRunDaDoRunRun$13$adapted(Runner.scala:1315)
	at scala.collection.immutable.List.foreach(List.scala:333)
	at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:1315)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24(Runner.scala:992)
	at org.scalatest.tools.Runner$.$anonfun$runOptionallyWithPassFailReporter$24$adapted(Runner.scala:970)
	at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:1481)
	at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:970)
	at org.scalatest.tools.Runner$.run(Runner.scala:798)
	at org.scalatest.tools.Runner.run(Runner.scala)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2or3(ScalaTestRunner.java:43)
	at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:26)