[
https://issues.apache.org/jira/browse/CAMEL-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen updated CAMEL-22922:
--------------------------------
Summary: Camel JBang stub option is broken when stubbing kafka (was: Camel
JBang stub option is broken)
> Camel JBang stub option is broken when stubbing kafka
> -----------------------------------------------------
>
> Key: CAMEL-22922
> URL: https://issues.apache.org/jira/browse/CAMEL-22922
> Project: Camel
> Issue Type: Bug
> Components: camel-jbang
> Affects Versions: 4.17.0
> Reporter: Christoph Deppisch
> Priority: Major
> Fix For: 4.18.0
>
>
> I am observing a regression when using the _*--stub*_ option in Camel JBang
> run command.
> Given this sample route with Kafka component:
>
> {noformat}
> - from:
> uri: "direct:echo"
> steps:
> - wireTap:
> uri: "log:info"
> - to:
> uri: "kafka:info?brokers=localhost:9092"
> {noformat}
> Run with the stub command option:
> {noformat}
> camel run route.yaml --stub=kafka{noformat}
> Then I get the following error:
>
> {noformat}
> org.apache.camel.FailedToCreateRouteException: Failed to create route: route1
> at: >>> to[kafka:info?brokers=localhost:9092] <<< in route:
> Route(route1)[From[direct:echo] -> [WireTap[log:info], to[ka... because:
> Failed to resolve endpoint: kafka://info?brokers=localhost:9092 due to:
> Cannot auto create component: kafka
> at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:248)
> at org.apache.camel.reifier.RouteReifier.createRoute(RouteReifier.java:89)
> at
> org.apache.camel.impl.DefaultModelReifierFactory.createRoute(DefaultModelReifierFactory.java:49)
> at
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:765)
> at
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:626)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doInit(AbstractCamelContext.java:2642)
> at org.apache.camel.support.service.BaseService.init(BaseService.java:85)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.init(AbstractCamelContext.java:2258)
> at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2277)
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:211)
> at org.apache.camel.main.KameletMain.doStart(KameletMain.java:404)
> at org.apache.camel.support.service.BaseService.start(BaseService.java:123)
> at org.apache.camel.dsl.jbang.core.commands.Run.runKameletMain(Run.java:1693)
> at org.apache.camel.dsl.jbang.core.commands.Run.run(Run.java:1025)
> at org.apache.camel.dsl.jbang.core.commands.Run.doCall(Run.java:378)
> at
> org.apache.camel.dsl.jbang.core.commands.CamelCommand.call(CamelCommand.java:72)
> at
> org.apache.camel.dsl.jbang.core.commands.CamelCommand.call(CamelCommand.java:38)
> at picocli.CommandLine.executeUserObject(CommandLine.java:2031)
> at picocli.CommandLine.access$1500(CommandLine.java:148)
> at
> picocli.CommandLine$RunLast.executeUserObjectOfLastSubcommandWithSameParent(CommandLine.java:2469)
> at picocli.CommandLine$RunLast.handle(CommandLine.java:2461)
> at picocli.CommandLine$RunLast.handle(CommandLine.java:2423)
> at
> picocli.CommandLine$AbstractParseResultHandler.execute(CommandLine.java:2277)
> at picocli.CommandLine$RunLast.execute(CommandLine.java:2425)
> at picocli.CommandLine.execute(CommandLine.java:2174)
> at
> org.apache.camel.dsl.jbang.core.commands.CamelJBangMain.run(CamelJBangMain.java:210)
> at
> org.apache.camel.dsl.jbang.core.commands.CamelJBangMain.run(CamelJBangMain.java:72)
> at main.CamelJBang.main(CamelJBang.java:36)
> Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve
> endpoint: kafka://info?brokers=localhost:9092 due to: Cannot auto create
> component: kafka
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:875)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:762)
> at
> org.apache.camel.support.CamelContextHelper.resolveEndpoint(CamelContextHelper.java:156)
> at org.apache.camel.reifier.SendReifier.resolveEndpoint(SendReifier.java:48)
> at org.apache.camel.reifier.SendReifier.createProcessor(SendReifier.java:37)
> at
> org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:851)
> at
> org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:619)
> at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:240)
> ... 28 more
> Caused by: org.apache.camel.RuntimeCamelException: Cannot auto create
> component: kafka
> at
> org.apache.camel.impl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:550)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:507)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:833)
> ... 35 more
> Caused by: org.apache.camel.RuntimeCamelException: Cannot auto create
> component: kafka
> at
> org.apache.camel.impl.engine.AbstractCamelContext.initComponent(AbstractCamelContext.java:598)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.lambda$getComponent$0(AbstractCamelContext.java:534)
> at
> java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.getComponent(AbstractCamelContext.java:532)
> ... 37 more
> Caused by: java.lang.ClassCastException: class
> org.apache.camel.component.stub.StubComponent cannot be cast to class
> org.apache.camel.component.kafka.KafkaComponent
> (org.apache.camel.component.stub.StubComponent is in unnamed module of loader
> 'app'; org.apache.camel.component.kafka.KafkaComponent is in unnamed module
> of loader org.apache.camel.main.download.DependencyDownloaderClassLoader
> @3bfc6a5e)
> at
> org.apache.camel.component.kafka.KafkaComponentConfigurer.getOptionValue(KafkaComponentConfigurer.java:515)
> at
> org.apache.camel.support.LifecycleStrategySupport.doAutoWire(LifecycleStrategySupport.java:255)
> at
> org.apache.camel.main.MainAutowiredLifecycleStrategy.autowire(MainAutowiredLifecycleStrategy.java:132)
> at
> org.apache.camel.main.MainAutowiredLifecycleStrategy.autowireComponent(MainAutowiredLifecycleStrategy.java:115)
> at
> org.apache.camel.main.MainAutowiredLifecycleStrategy.onComponentAdd(MainAutowiredLifecycleStrategy.java:75)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.postInitComponent(AbstractCamelContext.java:501)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.initComponent(AbstractCamelContext.java:595){noformat}
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
