API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Feb 2nd, 2023
32
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 17.38 KB | None | 0 0
raw download clone embed print report
  1. ╰─$ java -jar target/quarkus-app/quarkus-run.jar
  2.  
  3. __ ____ __ _____ ___ __ ____ ______
  4. --/ __ \/ / / / _ | / _ \/ //_/ / / / __/
  5. -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \
  6. --\___\_\____/_/ |_/_/|_/_/|_|\____/___/
  7. 2023-02-02 21:37:08,523 WARN [io.qua.config] (main) Unrecognized configuration key "kogito.persistence.type" was provided; it will be ignored; verify that the dependency extension for this configuration is set or that you did not make a typo
  8. 2023-02-02 21:37:09,335 INFO [io.qua.sma.ope.run.OpenApiRecorder] (main) CORS filtering is disabled and cross-origin resource sharing is allowed without restriction, which is not recommended in production. Please configure the CORS filter through 'quarkus.http.cors.*' properties. For more information, see Quarkus HTTP CORS documentation
  9. 2023-02-02 21:37:09,463 WARN [org.apa.kaf.cli.adm.AdminClientConfig] (main) These configurations '[group.id]' were supplied but are not used yet.
  10. 2023-02-02 21:37:09,733 WARN [org.apa.kaf.cli.pro.ProducerConfig] (main) These configurations '[group.id]' were supplied but are not used yet.
  11. 2023-02-02 21:37:09,734 INFO [org.kie.kog.per.KafkaProcessInstancesFactory] (main) Creating KafkaProcessInstances for process: dealreviews
  12. 2023-02-02 21:37:09,774 WARN [org.apa.kaf.cli.adm.AdminClientConfig] (main) These configurations '[ssl.endpoint.identification.algorithm]' were supplied but are not used yet.
  13. 2023-02-02 21:37:09,811 INFO [org.kie.kog.per.kaf.KafkaPersistenceUtils] (main) Created Kafka Stream GlobalTable
  14. 2023-02-02 21:37:09,822 INFO [org.apa.kaf.str.StreamsConfig] (main) StreamsConfig values:
  15. acceptable.recovery.lag = 10000
  16. application.id = kogito-persistence-example
  17. application.server =
  18. bootstrap.servers = [localhost:9092]
  19. buffered.records.per.partition = 1000
  20. built.in.metrics.version = latest
  21. cache.max.bytes.buffering = 10485760
  22. client.id =
  23. commit.interval.ms = 30000
  24. connections.max.idle.ms = 540000
  25. default.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler
  26. default.dsl.store = rocksDB
  27. default.key.serde = null
  28. default.list.key.serde.inner = null
  29. default.list.key.serde.type = null
  30. default.list.value.serde.inner = null
  31. default.list.value.serde.type = null
  32. default.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler
  33. default.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp
  34. default.value.serde = null
  35. max.task.idle.ms = 0
  36. max.warmup.replicas = 2
  37. metadata.max.age.ms = 300000
  38. metric.reporters = []
  39. metrics.num.samples = 2
  40. metrics.recording.level = INFO
  41. metrics.sample.window.ms = 30000
  42. num.standby.replicas = 0
  43. num.stream.threads = 1
  44. poll.ms = 100
  45. probing.rebalance.interval.ms = 600000
  46. processing.guarantee = at_least_once
  47. rack.aware.assignment.tags = []
  48. receive.buffer.bytes = 32768
  49. reconnect.backoff.max.ms = 1000
  50. reconnect.backoff.ms = 50
  51. repartition.purge.interval.ms = 30000
  52. replication.factor = -1
  53. request.timeout.ms = 40000
  54. retries = 0
  55. retry.backoff.ms = 100
  56. rocksdb.config.setter = null
  57. security.protocol = PLAINTEXT
  58. send.buffer.bytes = 131072
  59. state.cleanup.delay.ms = 600000
  60. state.dir = /var/folders/r1/9kx526qs4h71nvlj2vz2w8g00000gn/T//kafka-streams
  61. task.timeout.ms = 300000
  62. topology.optimization = none
  63. upgrade.from = null
  64. window.size.ms = null
  65. windowed.inner.class.serde = null
  66. windowstore.changelog.additional.retention.ms = 86400000
  67.  
  68. 2023-02-02 21:37:09,839 WARN [org.apa.kaf.str.pro.int.StateDirectory] (main) Using an OS temp directory in the state.dir property can cause failures with writing the checkpoint file due to the fact that this directory can be cleared by the OS. Resolved state.dir: [/var/folders/r1/9kx526qs4h71nvlj2vz2w8g00000gn/T//kafka-streams]
  69. 2023-02-02 21:37:09,871 INFO [org.apa.kaf.str.pro.int.StateDirectory] (main) Reading UUID from process file: 9b662424-eb99-4ad6-801c-3fb26a2c9638
  70. 2023-02-02 21:37:09,877 WARN [org.apa.kaf.cli.adm.AdminClientConfig] (main) These configurations '[topics, application-id, ssl.endpoint.identification.algorithm]' were supplied but are not used yet.
  71. 2023-02-02 21:37:09,878 WARN [org.apa.kaf.str.int.met.ClientMetrics] (main) Error while loading kafka-streams-version.properties: java.lang.NullPointerException: inStream parameter is null
  72. at java.base/java.util.Objects.requireNonNull(Objects.java:233)
  73. at java.base/java.util.Properties.load(Properties.java:407)
  74. at org.apache.kafka.streams.internals.metrics.ClientMetrics.<clinit>(ClientMetrics.java:53)
  75. at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:894)
  76. at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:856)
  77. at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:826)
  78. at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:738)
  79. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer.initializeKafkaStreams(KafkaStreamsProducer.java:156)
  80. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer.<init>(KafkaStreamsProducer.java:106)
  81. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_Bean.create(Unknown Source)
  82. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_Bean.create(Unknown Source)
  83. at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:113)
  84. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:37)
  85. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:34)
  86. at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
  87. at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
  88. at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:34)
  89. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_Bean.get(Unknown Source)
  90. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_Bean.get(Unknown Source)
  91. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_ProducerMethod_getKafkaStreams_7790cbc0b67cec783271544399d0fa71077d93dc_Bean.create(Unknown Source)
  92. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_ProducerMethod_getKafkaStreams_7790cbc0b67cec783271544399d0fa71077d93dc_Bean.create(Unknown Source)
  93. at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:113)
  94. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:37)
  95. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:34)
  96. at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
  97. at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
  98. at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:34)
  99. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_ProducerMethod_getKafkaStreams_7790cbc0b67cec783271544399d0fa71077d93dc_Bean.get(Unknown Source)
  100. at io.quarkus.kafka.streams.runtime.KafkaStreamsProducer_ProducerMethod_getKafkaStreams_7790cbc0b67cec783271544399d0fa71077d93dc_Bean.get(Unknown Source)
  101. at org.kie.kogito.persistence.kafka.KafkaStreamsStateListener_Bean.create(Unknown Source)
  102. at org.kie.kogito.persistence.kafka.KafkaStreamsStateListener_Bean.create(Unknown Source)
  103. at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:113)
  104. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:37)
  105. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:34)
  106. at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
  107. at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
  108. at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:34)
  109. at io.quarkus.arc.impl.ClientProxies.getApplicationScopedDelegate(ClientProxies.java:21)
  110. at org.kie.kogito.persistence.kafka.KafkaStreamsStateListener_ClientProxy.arc$delegate(Unknown Source)
  111. at org.kie.kogito.persistence.kafka.KafkaStreamsStateListener_ClientProxy.addProcessInstances(Unknown Source)
  112. at org.kie.kogito.persistence.KafkaProcessInstancesFactory.createProcessInstances(KafkaProcessInstancesFactory.java:67)
  113. at org.kie.kogito.persistence.KafkaProcessInstancesFactory.createProcessInstances(KafkaProcessInstancesFactory.java:36)
  114. at org.kie.kogito.persistence.KafkaProcessInstancesFactory_ClientProxy.createProcessInstances(Unknown Source)
  115. at org.kie.kogito.process.impl.AbstractProcess.configure(AbstractProcess.java:175)
  116. at org.kie.kogito.process.impl.AbstractProcess.activate(AbstractProcess.java:190)
  117. at org.acme.deals.DealreviewsProcess.<init>(DealreviewsProcess.java:18)
  118. at org.acme.deals.DealreviewsProcess_Bean.create(Unknown Source)
  119. at org.acme.deals.DealreviewsProcess_Bean.create(Unknown Source)
  120. at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:113)
  121. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:37)
  122. at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:34)
  123. at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
  124. at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
  125. at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:34)
  126. at io.quarkus.arc.impl.ClientProxies.getApplicationScopedDelegate(ClientProxies.java:21)
  127. at org.acme.deals.DealreviewsProcess_ClientProxy.arc$delegate(Unknown Source)
  128. at org.acme.deals.DealreviewsProcess_ClientProxy.arc_contextualInstance(Unknown Source)
  129. at org.acme.deals.DealreviewsProcess_Observer_Synthetic_43e2da52d323e2e62cfcaaaa0c0355fd0c6da5f5.notify(Unknown Source)
  130. at io.quarkus.arc.impl.EventImpl$Notifier.notifyObservers(EventImpl.java:328)
  131. at io.quarkus.arc.impl.EventImpl$Notifier.notify(EventImpl.java:310)
  132. at io.quarkus.arc.impl.EventImpl.fire(EventImpl.java:78)
  133. at io.quarkus.arc.runtime.ArcRecorder.fireLifecycleEvent(ArcRecorder.java:131)
  134. at io.quarkus.arc.runtime.ArcRecorder.handleLifecycleEvents(ArcRecorder.java:100)
  135. at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent1144526294.deploy_0(Unknown Source)
  136. at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent1144526294.deploy(Unknown Source)
  137. at io.quarkus.runner.ApplicationImpl.doStart(Unknown Source)
  138. at io.quarkus.runtime.Application.start(Application.java:101)
  139. at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:108)
  140. at io.quarkus.runtime.Quarkus.run(Quarkus.java:71)
  141. at io.quarkus.runtime.Quarkus.run(Quarkus.java:44)
  142. at io.quarkus.runtime.Quarkus.run(Quarkus.java:124)
  143. at io.quarkus.runner.GeneratedMain.main(Unknown Source)
  144. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  145. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
  146. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  147. at java.base/java.lang.reflect.Method.invoke(Method.java:568)
  148. at io.quarkus.bootstrap.runner.QuarkusEntryPoint.doRun(QuarkusEntryPoint.java:61)
  149. at io.quarkus.bootstrap.runner.QuarkusEntryPoint.main(QuarkusEntryPoint.java:32)
  150.  
  151. 2023-02-02 21:37:09,880 INFO [org.apa.kaf.str.KafkaStreams] (main) stream-client [kogito-persistence-example-9b662424-eb99-4ad6-801c-3fb26a2c9638] Kafka Streams version: unknown
  152. 2023-02-02 21:37:09,880 INFO [org.apa.kaf.str.KafkaStreams] (main) stream-client [kogito-persistence-example-9b662424-eb99-4ad6-801c-3fb26a2c9638] Kafka Streams commit ID: unknown
  153. 2023-02-02 21:37:09,884 INFO [org.apa.kaf.str.pro.int.TopologyMetadata] (main) stream-client [kogito-persistence-example-9b662424-eb99-4ad6-801c-3fb26a2c9638] Overriding number of StreamThreads to zero for global-only topology
  154. 2023-02-02 21:37:09,901 WARN [org.apa.kaf.cli.con.ConsumerConfig] (main) These configurations '[topics, application-id, ssl.endpoint.identification.algorithm]' were supplied but are not used yet.
  155. 2023-02-02 21:37:09,905 INFO [org.kie.kog.per.KafkaProcessInstancesFactory] (main) Creating KafkaProcessInstances for process: deals
  156. 2023-02-02 21:37:09,926 WARN [io.qua.kaf.str.run.KafkaStreamsProducer] (pool-6-thread-1) Waiting for topic(s) to be created: [kogito.process]
  157. 2023-02-02 21:37:09,970 INFO [io.quarkus] (main) process-kafka-persistence-quarkus 1.33.0.Final on JVM (powered by Quarkus 2.16.0.Final) started in 1.633s. Listening on: http://0.0.0.0:8080
  158. 2023-02-02 21:37:09,970 INFO [io.quarkus] (main) Profile prod activated.
  159. 2023-02-02 21:37:09,970 INFO [io.quarkus] (main) Installed features: [cdi, kafka-client, kafka-streams, kogito-addon-persistence-kafka-extension, kogito-decisions, kogito-predictions, kogito-processes, kogito-rules, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health, smallrye-openapi, swagger-ui, vertx]
  160. 2023-02-02 21:38:56,021 ERROR [io.qua.ver.htt.run.QuarkusErrorHandler] (executor-thread-0) HTTP Request to /deals failed, error id: c2b6fce9-bfed-4e69-9a3d-5fe5251816d7-1: org.jboss.resteasy.spi.UnhandledException: java.lang.RuntimeException: Failed to obtain Kafka Store for process: deals
  161. at org.jboss.resteasy.core.ExceptionHandler.handleApplicationException(ExceptionHandler.java:105)
  162. at org.jboss.resteasy.core.ExceptionHandler.handleException(ExceptionHandler.java:359)
  163. at org.jboss.resteasy.core.SynchronousDispatcher.writeException(SynchronousDispatcher.java:218)
  164. at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:519)
  165. at org.jboss.resteasy.core.SynchronousDispatcher.lambda$invoke$4(SynchronousDispatcher.java:261)
  166. at org.jboss.resteasy.core.SynchronousDispatcher.lambda$preprocess$0(SynchronousDispatcher.java:161)
  167. at org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
  168. at org.jboss.resteasy.core.SynchronousDispatcher.preprocess(SynchronousDispatcher.java:164)
  169. at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:247)
  170. at io.quarkus.resteasy.runtime.standalone.RequestDispatcher.service(RequestDispatcher.java:82)
  171. at io.quarkus.resteasy.runtime.standalone.VertxRequestHandler.dispatch(VertxRequestHandler.java:147)
  172. at io.quarkus.resteasy.runtime.standalone.VertxRequestHandler$1.run(VertxRequestHandler.java:93)
  173. at io.quarkus.vertx.core.runtime.VertxCoreRecorder$14.runWith(VertxCoreRecorder.java:576)
  174. at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2449)
  175. at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1478)
  176. at org.jboss.threads.DelegatingRunnable.run(DelegatingRunnable.java:29)
  177. at org.jboss.threads.ThreadLocalResettingRunnable.run(ThreadLocalResettingRunnable.java:29)
  178. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  179. at java.base/java.lang.Thread.run(Thread.java:833)
  180. Caused by: java.lang.RuntimeException: Failed to obtain Kafka Store for process: deals
  181. at org.kie.kogito.persistence.kafka.KafkaProcessInstances.getStoreAwait(KafkaProcessInstances.java:89)
  182. at org.kie.kogito.persistence.kafka.KafkaProcessInstances.getStore(KafkaProcessInstances.java:69)
  183. at org.kie.kogito.persistence.kafka.KafkaProcessInstances.getProcessInstanceById(KafkaProcessInstances.java:103)
  184. at org.kie.kogito.persistence.kafka.KafkaProcessInstances.create(KafkaProcessInstances.java:117)
  185. at org.kie.kogito.process.impl.AbstractProcessInstance.start(AbstractProcessInstance.java:288)
  186. at org.kie.kogito.process.impl.AbstractProcessInstance.start(AbstractProcessInstance.java:262)
  187. at org.kie.kogito.process.impl.ProcessServiceImpl.lambda$createProcessInstance$0(ProcessServiceImpl.java:68)
  188. at org.kie.kogito.services.uow.UnitOfWorkExecutor.executeInUnitOfWork(UnitOfWorkExecutor.java:37)
  189. at org.kie.kogito.process.impl.ProcessServiceImpl.createProcessInstance(ProcessServiceImpl.java:63)
  190. at org.acme.deals.DealsResource.createResource_deals(DealsResource.java:75)
  191. at org.acme.deals.DealsResource_ClientProxy.createResource_deals(Unknown Source)
  192. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  193. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
  194. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  195. at java.base/java.lang.reflect.Method.invoke(Method.java:568)
  196. at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:170)
  197. at org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:130)
  198. at org.jboss.resteasy.core.ResourceMethodInvoker.internalInvokeOnTarget(ResourceMethodInvoker.java:660)
  199. at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTargetAfterFilter(ResourceMethodInvoker.java:524)
  200. at org.jboss.resteasy.core.ResourceMethodInvoker.lambda$invokeOnTarget$2(ResourceMethodInvoker.java:474)
  201. at org.jboss.resteasy.core.interception.jaxrs.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:364)
  202. at org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTarget(ResourceMethodInvoker.java:476)
  203. at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:434)
  204. at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:408)
  205. at org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:69)
  206. at org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:492)
  207. ... 15 more
  208. Caused by: java.lang.RuntimeException: Timeout waiting to obtain Kafka Store for process: deals
  209. at org.kie.kogito.persistence.kafka.KafkaProcessInstances.getStoreAwait(KafkaProcessInstances.java:86)
  210. ... 40 more
  211.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!