qafro1 opened a new issue #1171:
URL: https://github.com/apache/camel-kafka-connector/issues/1171
I have an issue creating a CAMEL REST KAFKA-CONNECTOR in k8s and I just want
to ingress REST API payload in Kafka strimzi.
Any ideas of the resolve and I'll be able to test the Kafka connector.
```
kind: KafkaConnector
apiVersion: kafka.strimzi.io/v1alpha1
metadata:
name: rest-source
namespace: kafka
labels:
# must match connect cluster name
strimzi.io/cluster: my-connect
spec:
tasksMax: 1
class: org.apache.camel.kafkaconnector.rest.CamelRestSourceConnector
config:
topics: my-topic
camel.source.path.method: get
camel.source.path.path: http://api.open-notify.org/astros.json
camel.source.endpoint.produces: application/json
camel.source.endpoint.description: Calls API open notify
```
Error msg:
```
Connector Status:
Connector:
State: RUNNING
worker_id: xxx.xx.x.x:8083
Name: rest-source
Tasks:
Id: 0
State: FAILED
Trace: org.apache.kafka.connect.errors.ConnectException: Failed to
create and start Camel context
at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:144)
at
org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
at
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: org.apache.camel.FailedToStartRouteException: Failed to start
route route3 because of null
at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:122)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:270)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:157)
at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:115)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2889)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2702)
at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2665)
at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2431)
at org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:141)
... 8 more
Caused by: java.lang.IllegalStateException: Cannot find RestConsumerFactory
in Registry or as a Component to use
at
org.apache.camel.component.rest.RestEndpoint.createConsumer(RestEndpoint.java:602)
at
org.apache.camel.impl.engine.DefaultRoute.addServices(DefaultRoute.java:575)
at
org.apache.camel.impl.engine.DefaultRoute.onStartingServices(DefaultRoute.java:160)
at
org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:150)
at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:120)
```
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
