Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Trying to stand up your example and run #1

Open
edeandrea opened this issue Jun 29, 2021 · 1 comment
Open

Trying to stand up your example and run #1

edeandrea opened this issue Jun 29, 2021 · 1 comment

Comments

@edeandrea
Copy link

edeandrea commented Jun 29, 2021 •
edited
Loading

Hi @mgubaidullin awesome stuff here! I was trying to stand everything up and run it by following the directions in the README.

First I notice a bunch of exceptions in the logs on startup:

infinity-rest       | 2021-06-29 16:22:56,787 ERROR [io.qua.application] (main) Failed to start application (with profile prod): com.datastax.oss.driver.api.core.InvalidKeyspaceException: Invalid keyspace infinity_ks
infinity-rest       | 	at com.datastax.oss.driver.api.core.InvalidKeyspaceException.copy(InvalidKeyspaceException.java:34)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:149)
infinity-rest       | 	at com.datastax.oss.driver.api.core.session.SessionBuilder.build(SessionBuilder.java:633)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer.createCassandraClient(CassandraClientProducer.java:64)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.create(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.zig:334)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.create(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.zig:365)
infinity-rest       | 	at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:88)
infinity-rest       | 	at io.quarkus.arc.impl.ComputingCache$CacheFunction.lambda$apply$0(ComputingCache.java:99)
infinity-rest       | 	at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
infinity-rest       | 	at io.quarkus.arc.impl.ComputingCache.getValue(ComputingCache.java:41)
infinity-rest       | 	at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:25)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.arc$delegate(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.zig:93)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.getName(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.zig:720)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientStarter.startup(CassandraClientStarter.java:42)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientStarter_Observer_startup_ec660f568d7956325bdb80db26244131e6c54888.notify(CassandraClientStarter_Observer_startup_ec660f568d7956325bdb80db26244131e6c54888.zig:169)
infinity-rest       | 	at io.quarkus.arc.impl.EventImpl$Notifier.notifyObservers(EventImpl.java:282)
infinity-rest       | 	at io.quarkus.arc.impl.EventImpl$Notifier.notify(EventImpl.java:267)
infinity-rest       | 	at io.quarkus.arc.impl.EventImpl.fire(EventImpl.java:69)
infinity-rest       | 	at io.quarkus.arc.runtime.LifecycleEventRunner.fireStartupEvent(LifecycleEventRunner.java:23)
infinity-rest       | 	at io.quarkus.arc.runtime.ArcRecorder.handleLifecycleEvents(ArcRecorder.java:113)
infinity-rest       | 	at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy_0(LifecycleEventsBuildStep$startupEvent-858218658.zig:81)
infinity-rest       | 	at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent-858218658.deploy(LifecycleEventsBuildStep$startupEvent-858218658.zig:40)
infinity-rest       | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:620)
infinity-rest       | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-rest       | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-rest       | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-rest       | 
infinity-rest       | 2021-06-29 16:22:56,828 INFO  [com.dat.oss.dri.int.cor.tim.Clock] (vert.x-eventloop-thread-11) Using native clock for microsecond precision
infinity-rest       | 2021-06-29 16:22:56,844 INFO  [com.dat.oss.dri.int.cor.cha.ChannelFactory] (vert.x-eventloop-thread-6) [s1] Failed to connect with protocol DSE_V2, retrying with DSE_V1
infinity-rest       | 2021-06-29 16:22:56,854 INFO  [com.dat.oss.dri.int.cor.cha.ChannelFactory] (vert.x-eventloop-thread-2) [s1] Failed to connect with protocol DSE_V1, retrying with V4
infinity-rest       | 2021-06-29 16:22:57,007 ERROR [io.qua.run.StartupContext] (main) Running a shutdown task failed: com.datastax.oss.driver.api.core.InvalidKeyspaceException: Invalid keyspace infinity_ks
infinity-rest       | 	at com.datastax.oss.driver.api.core.InvalidKeyspaceException.copy(InvalidKeyspaceException.java:34)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:149)
infinity-rest       | 	at com.datastax.oss.driver.api.core.session.SessionBuilder.build(SessionBuilder.java:633)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer.createCassandraClient(CassandraClientProducer.java:64)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.create(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.zig:334)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.create(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_Bean.zig:365)
infinity-rest       | 	at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:88)
infinity-rest       | 	at io.quarkus.arc.impl.ComputingCache$CacheFunction.lambda$apply$0(ComputingCache.java:99)
infinity-rest       | 	at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
infinity-rest       | 	at io.quarkus.arc.impl.ComputingCache.getValue(ComputingCache.java:41)
infinity-rest       | 	at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:25)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.arc$delegate(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.zig:93)
infinity-rest       | 	at com.datastax.oss.quarkus.runtime.internal.quarkus.CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.close(CassandraClientProducer_ProducerMethod_createCassandraClient_5a0b52609e90a9192707435ea76168cd66433ddc_ClientProxy.zig:388)
infinity-rest       | 	at io.quarkus.runtime.StartupContext.runAllInReverseOrder(StartupContext.java:83)
infinity-rest       | 	at io.quarkus.runtime.StartupContext.close(StartupContext.java:72)
infinity-rest       | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:698)
infinity-rest       | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-rest       | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-rest       | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-rest       | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-rest       | 
infinity-rest       | 2021-06-29 16:22:57,021 INFO  [org.apa.kaf.cli.pro.KafkaProducer] (vert.x-worker-thread-0) [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
infinity-rest       | 2021-06-29 16:22:57,054 INFO  [org.apa.kaf.cli.pro.KafkaProducer] (vert.x-worker-thread-1) [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
infinity-rest       | 2021-06-29 16:22:57,072 INFO  [io.sma.rea.mes.provider] (main) SRMSG00207: Cancel subscriptions
infinity-rest       | 2021-06-29 16:22:57,095 WARN  [io.net.uti.con.DefaultPromise] (vert.x-eventloop-thread-3) An exception was thrown by com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded$$Lambda$575/0x0000000100532c40.operationComplete(): java.util.concurrent.RejectedExecutionException: event executor terminated
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:926)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:353)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:346)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:828)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:818)
infinity-rest       | 	at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:118)
infinity-rest       | 	at io.netty.util.concurrent.AbstractEventExecutor.submit(AbstractEventExecutor.java:115)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.lambda$connect$7(ControlConnection.java:443)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:604)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
infinity-rest       | 	at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
infinity-rest       | 	at io.netty.channel.AbstractChannel$CloseFuture.setClosed(AbstractChannel.java:1158)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.doClose0(AbstractChannel.java:760)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:736)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:607)
infinity-rest       | 	at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:762)
infinity-rest       | 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:524)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
infinity-rest       | 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
infinity-rest       | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-rest       | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-rest       | 
infinity-rest       | 2021-06-29 16:22:57,095 WARN  [io.net.uti.con.DefaultPromise] (vert.x-eventloop-thread-4) An exception was thrown by com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded$$Lambda$575/0x0000000100532c40.operationComplete(): java.util.concurrent.RejectedExecutionException: event executor terminated
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:926)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:353)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:346)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:828)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:818)
infinity-rest       | 	at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:118)
infinity-rest       | 	at io.netty.util.concurrent.AbstractEventExecutor.submit(AbstractEventExecutor.java:115)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.control.ControlConnection$SingleThreaded.lambda$connect$7(ControlConnection.java:443)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:604)
infinity-rest       | 	at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
infinity-rest       | 	at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
infinity-rest       | 	at io.netty.channel.AbstractChannel$CloseFuture.setClosed(AbstractChannel.java:1158)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.doClose0(AbstractChannel.java:760)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:736)
infinity-rest       | 	at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:607)
infinity-rest       | 	at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:762)
infinity-rest       | 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:524)
infinity-rest       | 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
infinity-rest       | 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
infinity-rest       | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-rest       | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-rest       | 
infinity-processor  | 2021-06-29 16:22:57,270 ERROR [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error starting CamelContext (infinity-processor) due to exception thrown: Failed to start route events-by-time because of null: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.Cluster.connect(Cluster.java:334)
infinity-processor  | 	at org.apache.camel.utils.cassandra.CassandraSessionHolder.start(CassandraSessionHolder.java:61)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStart(CassandraEndpoint.java:130)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:228)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:215)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:236)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.access$2600(RequestHandler.java:62)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:1005)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:808)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1240)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1158)
infinity-processor  | 	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
infinity-processor  | 	at com.datastax.driver.core.InboundTrafficMeter.channelRead(InboundTrafficMeter.java:38)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
infinity-processor  | 	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
infinity-processor  | 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
infinity-processor  | 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:22:57,276 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) is shutting down
infinity-processor  | 2021-06-29 16:22:57,282 INFO  [org.apa.cam.com.kaf.KafkaConsumer] (main) Stopping Kafka consumer on topic: events
infinity-processor  | 2021-06-29 16:22:57,283 INFO  [org.apa.kaf.cli.pro.KafkaProducer] (main) [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
infinity-processor  | 2021-06-29 16:22:57,298 WARN  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error occurred while shutting down service: cql://bean:clusterRef/infinity_ks?cql=insert+into+events_by_timestamp+%28id%2C+event_group%2C+event_type%2C+event_timestamp%2C+value%29+values+%28%3F%2C+%3F%2C+%3F%2C+%3F%2C+%3F%29. This exception will be ignored.: java.lang.NullPointerException
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStop(CassandraEndpoint.java:136)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopService(ServiceHelper.java:133)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopAndShutdownService(ServiceHelper.java:198)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2983)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:3008)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2996)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStop(AbstractCamelContext.java:2898)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:121)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:22:57,301 WARN  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error occurred while shutting down service: cql://bean:clusterRef/infinity_ks?cql=insert+into+events_by_id+%28id%2C+event_group%2C+event_type%2C+event_timestamp%2C+value%29+values+%28%3F%2C+%3F%2C+%3F%2C+%3F%2C+%3F%29. This exception will be ignored.: java.lang.NullPointerException
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStop(CassandraEndpoint.java:136)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopService(ServiceHelper.java:133)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopAndShutdownService(ServiceHelper.java:198)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2983)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:3008)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2996)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStop(AbstractCamelContext.java:2898)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:121)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:22:57,302 INFO  [org.apa.cam.mai.MainLifecycleStrategy] (main) CamelContext: infinity-processor has been shutdown, triggering shutdown of the JVM.
infinity-processor  | 2021-06-29 16:22:57,304 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) uptime 1.910 seconds
infinity-processor  | 2021-06-29 16:22:57,304 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) is shutdown in 0.028 seconds
infinity-processor  | 2021-06-29 16:22:57,305 ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main) Failed to start application: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.Cluster.connect(Cluster.java:334)
infinity-processor  | 	at org.apache.camel.utils.cassandra.CassandraSessionHolder.start(CassandraSessionHolder.java:61)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStart(CassandraEndpoint.java:130)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:228)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:215)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:236)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.access$2600(RequestHandler.java:62)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:1005)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:808)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1240)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1158)
infinity-processor  | 	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
infinity-processor  | 	at com.datastax.driver.core.InboundTrafficMeter.channelRead(InboundTrafficMeter.java:38)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
infinity-processor  | 	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
infinity-processor  | 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
infinity-processor  | 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:22:57,306 ERROR [io.qua.application] (main) Failed to start application (with profile prod): java.lang.RuntimeException: java.lang.RuntimeException: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:47)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: java.lang.RuntimeException: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:65)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	... 9 more
infinity-processor  | Caused by: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	... 10 more
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.Cluster.connect(Cluster.java:334)
infinity-processor  | 	at org.apache.camel.utils.cassandra.CassandraSessionHolder.start(CassandraSessionHolder.java:61)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStart(CassandraEndpoint.java:130)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:228)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: Keyspace 'infinity_ks' does not exist
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:215)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:236)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler.access$2600(RequestHandler.java:62)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:1005)
infinity-processor  | 	at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:808)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1240)
infinity-processor  | 	at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1158)
infinity-processor  | 	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
infinity-processor  | 	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
infinity-processor  | 	at com.datastax.driver.core.InboundTrafficMeter.channelRead(InboundTrafficMeter.java:38)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
infinity-processor  | 	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
infinity-processor  | 	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
infinity-processor  | 	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
infinity-processor  | 	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
infinity-processor  | 	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
infinity-processor  | 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:23:03,413 ERROR [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error starting CamelContext (infinity-processor) due to exception thrown: Failed to start route events-by-time because of null: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:86)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:168)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:179)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraProducer.doStart(CassandraProducer.java:54)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.start(AsyncProcessorConverterHelper.java:107)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1486)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1406)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:234)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:250)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:219)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:213)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:202)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:118)
infinity-processor  | 	at com.google.common.util.concurrent.MoreExecutors$5$1.run(MoreExecutors.java:982)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:23:03,418 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) is shutting down
infinity-processor  | 2021-06-29 16:23:03,427 INFO  [org.apa.cam.com.kaf.KafkaConsumer] (main) Stopping Kafka consumer on topic: events
infinity-processor  | 2021-06-29 16:23:03,427 INFO  [org.apa.kaf.cli.pro.KafkaProducer] (main) [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
infinity-processor  | 2021-06-29 16:23:03,447 WARN  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error occurred while shutting down service: cql://bean:clusterRef/infinity_ks?cql=insert+into+events_by_timestamp+%28id%2C+event_group%2C+event_type%2C+event_timestamp%2C+value%29+values+%28%3F%2C+%3F%2C+%3F%2C+%3F%2C+%3F%29. This exception will be ignored.: java.lang.NullPointerException
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStop(CassandraEndpoint.java:136)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopService(ServiceHelper.java:133)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopAndShutdownService(ServiceHelper.java:198)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2983)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:3008)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2996)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStop(AbstractCamelContext.java:2898)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:121)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:23:03,449 WARN  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Error occurred while shutting down service: cql://bean:clusterRef/infinity_ks?cql=insert+into+events_by_id+%28id%2C+event_group%2C+event_type%2C+event_timestamp%2C+value%29+values+%28%3F%2C+%3F%2C+%3F%2C+%3F%2C+%3F%29. This exception will be ignored.: java.lang.NullPointerException
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.doStop(CassandraEndpoint.java:136)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopService(ServiceHelper.java:133)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.stopAndShutdownService(ServiceHelper.java:198)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2983)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:3008)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.shutdownServices(AbstractCamelContext.java:2996)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStop(AbstractCamelContext.java:2898)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.stop(BaseService.java:155)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:121)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:23:03,450 INFO  [org.apa.cam.mai.MainLifecycleStrategy] (main) CamelContext: infinity-processor has been shutdown, triggering shutdown of the JVM.
infinity-processor  | 2021-06-29 16:23:03,452 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) uptime 1.677 seconds
infinity-processor  | 2021-06-29 16:23:03,452 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.4.2 (infinity-processor) is shutdown in 0.035 seconds
infinity-processor  | 2021-06-29 16:23:03,453 ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main) Failed to start application: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:86)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:168)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:179)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraProducer.doStart(CassandraProducer.java:54)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.start(AsyncProcessorConverterHelper.java:107)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1486)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1406)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:234)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:250)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:219)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:213)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:202)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:118)
infinity-processor  | 	at com.google.common.util.concurrent.MoreExecutors$5$1.run(MoreExecutors.java:982)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  | 
infinity-processor  | 2021-06-29 16:23:03,454 ERROR [io.qua.application] (main) Failed to start application (with profile prod): java.lang.RuntimeException: java.lang.RuntimeException: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:47)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
infinity-processor  | 	at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
infinity-processor  | 	at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:512)
infinity-processor  | 	at io.quarkus.runtime.Application.start(Application.java:90)
infinity-processor  | 	at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:92)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:61)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
infinity-processor  | 	at io.quarkus.runtime.Quarkus.run(Quarkus.java:106)
infinity-processor  | 	at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
infinity-processor  | Caused by: java.lang.RuntimeException: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:65)
infinity-processor  | 	at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
infinity-processor  | 	... 9 more
infinity-processor  | Caused by: org.apache.camel.FailedToStartRouteException: Failed to start route events-by-time because of null
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
infinity-processor  | 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:73)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
infinity-processor  | 	at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
infinity-processor  | 	... 10 more
infinity-processor  | Caused by: org.apache.camel.RuntimeCamelException: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:67)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.channel.DefaultChannel.doStart(DefaultChannel.java:143)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:87)
infinity-processor  | 	at org.apache.camel.processor.Pipeline.doStart(Pipeline.java:154)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.startChildService(RouteService.java:334)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:184)
infinity-processor  | 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:123)
infinity-processor  | 	... 22 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:49)
infinity-processor  | 	at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:35)
infinity-processor  | 	at com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:86)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:168)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraEndpoint.prepareStatement(CassandraEndpoint.java:179)
infinity-processor  | 	at org.apache.camel.component.cassandra.CassandraProducer.doStart(CassandraProducer.java:54)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.start(AsyncProcessorConverterHelper.java:107)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.internalAddService(AbstractCamelContext.java:1486)
infinity-processor  | 	at org.apache.camel.impl.engine.AbstractCamelContext.addService(AbstractCamelContext.java:1406)
infinity-processor  | 	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:234)
infinity-processor  | 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:84)
infinity-processor  | 	at org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:101)
infinity-processor  | 	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1459)
infinity-processor  | 	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:60)
infinity-processor  | 	... 37 more
infinity-processor  | Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table events_by_time
infinity-processor  | 	at com.datastax.driver.core.Responses$Error.asException(Responses.java:181)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:250)
infinity-processor  | 	at com.datastax.driver.core.SessionManager$4.apply(SessionManager.java:219)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:213)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture$AsyncTransformFuture.doTransform(AbstractTransformFuture.java:202)
infinity-processor  | 	at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:118)
infinity-processor  | 	at com.google.common.util.concurrent.MoreExecutors$5$1.run(MoreExecutors.java:982)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
infinity-processor  | 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
infinity-processor  | 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
infinity-processor  | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-processor  |

I also notice infinity-rest exited with code 1 in the logs at startup.

I am able to browse to http://localhost:8080. When I upload the file everything seems to work (I watch the docker compose log):

infinity-processor  | 2021-06-29 16:12:01,380 INFO  [events-by-time] (Camel (infinity-processor) thread #0 - KafkaConsumer[events]) Event stored to Cassandra

but when I refresh the browser page I'm seeing this error in the console:

infinity-rest       | 2021-06-29 16:12:10,576 WARN  [org.jbo.res.res.i18n] (executor-thread-1) RESTEASY002142: Multiple resource methods match request "GET /events/Quebec/Trucks/2222-08-12T15:52:42.942Z". Selecting one. Matching methods: [public io.smallrye.mutiny.Uni one.entropy.infinity.rest.event.EventResource.getEventById(java.lang.String,java.lang.String,java.lang.String), public io.smallrye.mutiny.Multi one.entropy.infinity.rest.event.EventResource.getEventsByTimestamp(java.lang.String,java.lang.String,java.lang.String)]
infinity-rest       | 2021-06-29 16:12:10,577 ERROR [org.jbo.res.res.i18n] (executor-thread-1) RESTEASY002020: Unhandled asynchronous exception, sending back 500: com.datastax.oss.driver.api.core.type.codec.CodecNotFoundException: Codec not found for requested operation: [UUID <-> java.lang.String]
infinity-rest       | 	at com.datastax.oss.driver.internal.core.type.codec.registry.CachingCodecRegistry.createCodec(CachingCodecRegistry.java:609)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry$1.load(DefaultCodecRegistry.java:95)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry$1.load(DefaultCodecRegistry.java:92)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2276)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2154)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.get(LocalCache.java:2044)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache.get(LocalCache.java:3951)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache.getOrLoad(LocalCache.java:3973)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4957)
infinity-rest       | 	at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4963)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry.getCachedCodec(DefaultCodecRegistry.java:117)
infinity-rest       | 	at com.datastax.oss.driver.internal.core.type.codec.registry.CachingCodecRegistry.codecFor(CachingCodecRegistry.java:215)
infinity-rest       | 	at com.datastax.oss.driver.api.core.data.SettableByIndex.set(SettableByIndex.java:132)
infinity-rest       | 	at com.datastax.oss.driver.api.core.data.SettableByName.set(SettableByName.java:146)
infinity-rest       | 	at one.entropy.infinity.rest.event.storage.EventDaoImpl__MapperGenerated.findEventById(EventDaoImpl__MapperGenerated.java:99)
infinity-rest       | 	at one.entropy.infinity.rest.event.storage.EventDaoProducer_ProducerMethod_produceEventDao_a8a477e124e4fea372b2333ab6fca03f2c2caef6_ClientProxy.findEventById(EventDaoProducer_ProducerMethod_produceEventDao_a8a477e124e4fea372b2333ab6fca03f2c2caef6_ClientProxy.zig:163)
infinity-rest       | 	at one.entropy.infinity.rest.event.storage.EventService.getEventById(EventService.java:20)
infinity-rest       | 	at one.entropy.infinity.rest.event.storage.EventService_ClientProxy.getEventById(EventService_ClientProxy.zig:228)
infinity-rest       | 	at one.entropy.infinity.rest.event.EventResource.getEventById(EventResource.java:87)
infinity-rest       | 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
infinity-rest       | 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
infinity-rest       | 	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
infinity-rest       | 	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
infinity-rest       | 	at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:167)
infinity-rest       | 	at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:130)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.internalInvokeOnTarget(ResourceMethodInvoker.java:638)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTargetAfterFilter(ResourceMethodInvoker.java:504)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.lambda$invokeOnTarget$2(ResourceMethodInvoker.java:454)
infinity-rest       | 	at org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTarget(ResourceMethodInvoker.java:456)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:417)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:391)
infinity-rest       | 	at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:68)
infinity-rest       | 	at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:488)
infinity-rest       | 	at org.jboss.resteasy.core.SynchronousDispatcher.lambda$invoke$4(SynchronousDispatcher.java:259)
infinity-rest       | 	at org.jboss.resteasy.core.SynchronousDispatcher.lambda$preprocess$0(SynchronousDispatcher.java:160)
infinity-rest       | 	at org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
infinity-rest       | 	at org.jboss.resteasy.core.SynchronousDispatcher.preprocess(SynchronousDispatcher.java:163)
infinity-rest       | 	at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:245)
infinity-rest       | 	at io.quarkus.resteasy.runtime.standalone.RequestDispatcher.service(RequestDispatcher.java:73)
infinity-rest       | 	at io.quarkus.resteasy.runtime.standalone.VertxRequestHandler.dispatch(VertxRequestHandler.java:132)
infinity-rest       | 	at io.quarkus.resteasy.runtime.standalone.VertxRequestHandler.access$000(VertxRequestHandler.java:37)
infinity-rest       | 	at io.quarkus.resteasy.runtime.standalone.VertxRequestHandler$1.run(VertxRequestHandler.java:94)
infinity-rest       | 	at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
infinity-rest       | 	at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2046)
infinity-rest       | 	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1578)
infinity-rest       | 	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1452)
infinity-rest       | 	at org.jboss.threads.DelegatingRunnable.run(DelegatingRunnable.java:29)
infinity-rest       | 	at org.jboss.threads.ThreadLocalResettingRunnable.run(ThreadLocalResettingRunnable.java:29)
infinity-rest       | 	at java.base/java.lang.Thread.run(Thread.java:829)
infinity-rest       | 	at org.jboss.threads.JBossThread.run(JBossThread.java:479)

Am I missing something?
@mgubaidullin
Copy link
Owner

@edeandrea are you trying to start docker-compose up or just infinity-rest?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@edeandrea @mgubaidullin