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
