tarilabs commented on issue #3937:
URL: https://github.com/apache/camel-k/issues/3937#issuecomment-1359330446
So, an update. I've mixed @squakez and @lburgazzoli suggestions. Local kamel
works, Kamelet does not, ~same flow per Camel doc suggestions.
## local flow (works)
this
```yaml
# camel-k: language=yaml
dependency=github:kiegroup.yard/yard-kdtable/camelk-SNAPSHOT
- beans:
- name: myp
type: org.drools.yard.kdtable.KdtableProcessor
- from:
uri: "timer:yaml"
parameters:
period: "5000"
steps:
- setBody:
constant: "Hello Camel K from yaml"
- process:
ref: myp
- transform:
simple: "${body.toUpperCase()}"
- to: "log:info"
```
works:
```
$ kamel local run test.yaml --verbose
Modeline options have been loaded from source files
Full command: kamel local run test.yaml --verbose
--dependency=github:kiegroup.yard/yard-kdtable/camelk-SNAPSHOT
Command "run" is deprecated, consider using Camel JBang instead
(https://camel.apache.org/manual/camel-jbang.html)
Executing: java -cp test.yaml:
...
{"timestamp":"2022-12-20T14:05:39.855+01:00","sequence":175,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"Profile
prod activated.
","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:39.855+01:00","sequence":176,"loggerClassName":"org.jboss.logging.Logger","loggerName":"io.quarkus","level":"INFO","message":"Installed
features: [camel-bean, camel-core, camel-k-core, camel-k-runtime,
camel-kubernetes, camel-log, camel-timer, camel-yaml-dsl, cdi,
kubernetes-client,
security]","threadName":"main","threadId":1,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:40.861+01:00","sequence":177,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.drools.yard.kdtable.KdtableProcessor","level":"INFO","message":"for
prop key kdtable value Optional.empty","threadName":"Camel (camel-1) thread #1
-
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:40.889+01:00","sequence":178,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"info","level":"INFO","message":"Exchange[ExchangePattern:
InOnly, BodyType: String, Body: HELLO CAMEL K FROM YAML]","threadName":"Camel
(camel-1) thread #1 -
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:45.855+01:00","sequence":179,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.drools.yard.kdtable.KdtableProcessor","level":"INFO","message":"for
prop key kdtable value Optional.empty","threadName":"Camel (camel-1) thread #1
-
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:45.857+01:00","sequence":180,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"info","level":"INFO","message":"Exchange[ExchangePattern:
InOnly, BodyType: String, Body: HELLO CAMEL K FROM YAML]","threadName":"Camel
(camel-1) thread #1 -
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:50.86+01:00","sequence":181,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"org.drools.yard.kdtable.KdtableProcessor","level":"INFO","message":"for
prop key kdtable value Optional.empty","threadName":"Camel (camel-1) thread #1
-
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
{"timestamp":"2022-12-20T14:05:50.861+01:00","sequence":182,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"info","level":"INFO","message":"Exchange[ExchangePattern:
InOnly, BodyType: String, Body: HELLO CAMEL K FROM YAML]","threadName":"Camel
(camel-1) thread #1 -
timer://yaml","threadId":17,"mdc":{},"ndc":"","hostName":"mmortari1-mac","processName":"io.quarkus.bootstrap.runner.QuarkusEntryPoint","processId":31044}
...
```
## ~same flow in kamelet (not working 🤷 )
but this kamelet:
```yaml
apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
name: mmk
labels:
camel.apache.org/kamelet.type: "action"
spec:
definition:
title: "mmk"
description: prova
properties:
milliseconds:
title: Milliseconds
description: The number of milliseconds of delay
type: integer
example: 1000
yard.kdtable:
title: prova
description: prova
type: object
dependencies:
- "camel:core"
- "camel:kamelet"
- "github:kiegroup.yard/yard-kdtable/camelk-SNAPSHOT"
template:
beans:
- name: myp
type: org.drools.yard.kdtable.KdtableProcessor
from:
uri: "kamelet:source"
steps:
- process:
ref: myp
- to: "log:info"
```
with this binding:
```yaml
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: timer-source-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: timer-source
properties:
message: hello world
period: 5000
sink:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: mmk
properties:
yard.kdtable: my asd value in KameletBinding
```
gives me:
```
2022-12-20 13:04:00,540 INFO [org.apa.cam.k.Runtime] (main) Apache Camel K
Runtime 1.16.0
2022-12-20 13:04:00,567 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder]
(main) Bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime
2022-12-20 13:04:00,569 INFO [org.apa.cam.mai.MainSupport] (main) Apache
Camel (Main) 3.19.0 is starting
2022-12-20 13:04:00,617 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main)
Loading routes from: SourceDefinition{name='camel-k-embedded-flow',
language='yaml', type='source',
location='file:/etc/camel/sources/camel-k-embedded-flow.yaml', }
2022-12-20 13:04:00,659 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main)
Loading routes from: SourceDefinition{name='mmk', language='yaml',
type='source', location='file:/etc/camel/sources/mmk.yaml', }
2022-12-20 13:04:00,661 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main)
Loading routes from: SourceDefinition{name='timer-source', language='yaml',
type='source', location='file:/etc/camel/sources/timer-source.yaml', }
2022-12-20 13:04:00,883 WARN [org.apa.cam.imp.eng.AbstractCamelContext]
(main) Lifecycle strategy
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler@6e4c0d8c
vetoed initializing CamelContext (camel-1) due to: Failure creating route from
template: mmk
2022-12-20 13:04:00,883 INFO [org.apa.cam.imp.eng.AbstractCamelContext]
(main) CamelContext (camel-1) vetoed to not initialize due to: Failure creating
route from template: mmk
2022-12-20 13:04:00,884 ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main)
Failed to start application: org.apache.camel.RuntimeCamelException:
org.apache.camel.VetoCamelContextStartException: Failure creating route from
template: mmk
at
org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:66)
at org.apache.camel.support.service.BaseService.doFail(BaseService.java:413)
at
org.apache.camel.impl.engine.AbstractCamelContext.doFail(AbstractCamelContext.java:3613)
at org.apache.camel.support.service.BaseService.fail(BaseService.java:342)
at
org.apache.camel.impl.engine.AbstractCamelContext.failOnStartup(AbstractCamelContext.java:5302)
at
org.apache.camel.impl.engine.AbstractCamelContext.init(AbstractCamelContext.java:2683)
at org.apache.camel.support.service.BaseService.start(BaseService.java:111)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2690)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:94)
at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:140)
at
org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
at
org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
at
io.quarkus.deployment.steps.CamelBootstrapProcessor$boot173480958.deploy_0(Unknown
Source)
at
io.quarkus.deployment.steps.CamelBootstrapProcessor$boot173480958.deploy(Unknown
Source)
at io.quarkus.runner.ApplicationImpl.doStart(Unknown Source)
at io.quarkus.runtime.Application.start(Application.java:101)
at
io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:110)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:70)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:43)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:123)
at io.quarkus.runner.GeneratedMain.main(Unknown Source)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
io.quarkus.bootstrap.runner.QuarkusEntryPoint.doRun(QuarkusEntryPoint.java:61)
at
io.quarkus.bootstrap.runner.QuarkusEntryPoint.main(QuarkusEntryPoint.java:32)
Caused by: org.apache.camel.VetoCamelContextStartException: Failure creating
route from template: mmk
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.onContextInitialized(KameletComponent.java:433)
at
org.apache.camel.impl.engine.AbstractCamelContext.doInit(AbstractCamelContext.java:3009)
at
org.apache.camel.quarkus.core.FastCamelContext.doInit(FastCamelContext.java:174)
at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
at
org.apache.camel.impl.engine.AbstractCamelContext.init(AbstractCamelContext.java:2671)
... 23 more
Caused by: org.apache.camel.component.kamelet.KameletNotFoundException:
Kamelet with id mmk not found in locations: classpath:/kamelets
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:421)
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.onContextInitialized(KameletComponent.java:430)
... 27 more
Caused by: java.lang.IllegalArgumentException: Route template local bean:
myp has invalid type syntax: org.drools.yard.kdtable.KdtableProcessor. To refer
to a class then prefix the value with #class such as:
#class:fullyQualifiedClassName
at org.apache.camel.impl.DefaultModel.bind(DefaultModel.java:650)
at
org.apache.camel.impl.DefaultModel.addTemplateBeans(DefaultModel.java:488)
at
org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:448)
at
org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:350)
at
org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:458)
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:409)
... 28 more
2022-12-20 13:04:00,919 ERROR [io.qua.run.Application] (main) Failed to
start application (with profile prod): java.lang.IllegalArgumentException:
Route template local bean: myp has invalid type syntax:
org.drools.yard.kdtable.KdtableProcessor. To refer to a class then prefix the
value with #class such as: #class:fullyQualifiedClassName
at org.apache.camel.impl.DefaultModel.bind(DefaultModel.java:650)
at
org.apache.camel.impl.DefaultModel.addTemplateBeans(DefaultModel.java:488)
at
org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:448)
at
org.apache.camel.impl.DefaultModel.addRouteFromTemplate(DefaultModel.java:350)
at
org.apache.camel.impl.DefaultCamelContext.addRouteFromTemplate(DefaultCamelContext.java:458)
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.createRouteForEndpoint(KameletComponent.java:409)
at
org.apache.camel.component.kamelet.KameletComponent$LifecycleHandler.onContextInitialized(KameletComponent.java:430)
at
org.apache.camel.impl.engine.AbstractCamelContext.doInit(AbstractCamelContext.java:3009)
at
org.apache.camel.quarkus.core.FastCamelContext.doInit(FastCamelContext.java:174)
at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
at
org.apache.camel.impl.engine.AbstractCamelContext.init(AbstractCamelContext.java:2671)
at org.apache.camel.support.service.BaseService.start(BaseService.java:111)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2690)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:262)
at org.apache.camel.quarkus.main.CamelMain.doStart(CamelMain.java:94)
at org.apache.camel.support.service.BaseService.start(BaseService.java:119)
at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:140)
at
org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
at
org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
at
io.quarkus.deployment.steps.CamelBootstrapProcessor$boot173480958.deploy_0(Unknown
Source)
at
io.quarkus.deployment.steps.CamelBootstrapProcessor$boot173480958.deploy(Unknown
Source)
at io.quarkus.runner.ApplicationImpl.doStart(Unknown Source)
at io.quarkus.runtime.Application.start(Application.java:101)
at
io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:110)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:70)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:43)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:123)
at io.quarkus.runner.GeneratedMain.main(Unknown Source)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
io.quarkus.bootstrap.runner.QuarkusEntryPoint.doRun(QuarkusEntryPoint.java:61)
at
io.quarkus.bootstrap.runner.QuarkusEntryPoint.main(QuarkusEntryPoint.java:32)
```
In the integration Pod.
Suggestions, please? 🤔
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
