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