As example use the official one https://github.com/apache/camel-kafka-connector-examples/blob/master/aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties
Il sab 26 dic 2020, 09:59 Andrea Cosentino <anco...@gmail.com> ha scritto: > Can you show your full configuration? > > Il sab 26 dic 2020, 07:40 Arundhati Bhende < > arundhati.bhe...@prudential.com> ha scritto: > >> I am trying to test The Camel S3 Source connector using basic example >> from this link >> https://dzone.com/articles/reading-aws-s3-file-content-to-kafka-topic. >> Below is the file I am uploading to S3. >> >> testfile.txt >> add one line >> add another line >> test the connector >> >> >> After the connector picks up and processes the file, If I use this for >> value converter >> >> >> value.converter=org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter >> >> When I run the consumer, it shows the message processed but the output >> shows blank. >> >> If I use the String converter as value converter >> >> org.apache.kafka.connect.storage.StringConverter >> >> I get the output in the form of >> >> com.amazonaws.services.s3.model.S3ObjectInputStream@522e135a >> com.amazonaws.services.s3.model.S3ObjectInputStream@6c6cf103 >> >> From the example in the above link, the author doesn't seem to have to do >> any actions to see the string. >> >> So, why would the S3ObjectConverter show a blank output for me? I can >> understand the String representation for the object really shows the memory >> address. >> >> What do I need to look at to fix the output. >> >> Also, is it possible to change the converter to JSON or Avro converter in >> the configuration file or I need to add either different properties to the >> configuration or do some processing afterwards? >> >> Thank You >> >>
