w4rdy opened a new issue, #1543:
URL: https://github.com/apache/camel-kafka-connector/issues/1543

   Hi @oscerd,
   
   I'm attempting to use the CamelPostgresqlsourceSourceConnector. I can create 
the connector but it publishes an InputStreamCache object reference to the 
topic, in the form:
   
   ```
   org.apache.camel.converter.stream.InputStreamCache@6e37b6bd
   org.apache.camel.converter.stream.InputStreamCache@6c833187
   org.apache.camel.converter.stream.InputStreamCache@59bcea5a
   org.apache.camel.converter.stream.InputStreamCache@4235ec9b
   org.apache.camel.converter.stream.InputStreamCache@1fd4716e
   org.apache.camel.converter.stream.InputStreamCache@3a08393d
   org.apache.camel.converter.stream.InputStreamCache@2e2bb2c
   org.apache.camel.converter.stream.InputStreamCache@c2ac46c
   org.apache.camel.converter.stream.InputStreamCache@2a224dd6
   org.apache.camel.converter.stream.InputStreamCache@1437780
   ...
   ```
   
   Is there any additional config I need to set to get the connector to publish 
something that a consumer can easily utilise?
   
   Here is my connector config:
   
   ```json
   {
       "name": "source",
       "config": {
           "connector.class": 
"org.apache.camel.kafkaconnector.postgresqlsource.CamelPostgresqlsourceSourceConnector",
           "tasks.max": "1",
           "topics": "test-topic",
           "camel.kamelet.postgresql-source.databaseName": "db",
           "camel.kamelet.postgresql-source.query": "SELECT (id,name) FROM 
source;",
           "camel.kamelet.postgresql-source.serverName": "postgres",
           "camel.kamelet.postgresql-source.username": "postgres",
           "camel.kamelet.postgresql-source.password": "postgres",
           "camel.kamelet.postgresql-source.delay": 2000
       }
   }
   ```
   
   Thanks


-- 
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.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to