sonic-martin opened a new issue #1242:
URL: https://github.com/apache/camel-kafka-connector/issues/1242


   # Description
   
   Hey,
   
   I tried to use the ```camel-influxdb-kafka-connector``` via Strimzi and 
Kafka Connect.
   But as the Connection setup in the [Camel InfluxDB 
Component](https://camel.apache.org/components/latest/influxdb-component.html)  
doesnt happens via String parameters, but with a Bean, it doesnt works without 
manually work.
   
   # Setup
   
   Kafka Connect and InfluxDB works and the KafkaConnector is setup like that:
   ```
   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: connector
     labels:
       strimzi.io/cluster: kafka-connect-cluster
   spec:
     class: org.apache.camel.kafkaconnector.influxdb.CamelInfluxdbSinkConnector
     tasksMax: 1
     config:
       topics: mytopic
       camel.sink.path.connectionBean: influxdb://influxDB
       camel.sink.endpoint.databaseName: mytopic
       camel.component.influxdb.influxDB: http://influxpath:8428
   ```
   
   # Expected Result
   
   
   # Actual result
   
   Result is:
   ```
   Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to 
resolve endpoint: influxdb://influxdb://influxDB?databaseName=mytopic due to: 
No bean could be found in the registry for: influxdb://influxDB of type: 
org.influxdb.InfluxDB
   ```
   
   # Proposed Solution
   
   I didnt tried it, but I think the Camel InfluxDB Component has to be 
changed, so it also can be configured with String parameter and creating based 
on that the InfluxDB Class Object. Maybe that also could happen in the 
camel-influxdb-kafka-connector Component.
   
   


-- 
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


Reply via email to