gohanbg commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-766339293
Hello @valdar, Apologies for the delay, it was a busy week and I just managed to test the fix. Not sure whether I'm doing something wrong, but I get the same error. ``` Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: org.apache.kafka.connect.data.Struct to the required type: java.io.InputStream with value Struct{company_name=House Stark,logo_url=https://static.wikia.nocookie.net/gameofthrones/images/8/8a/House-Stark-Main-Shield.PNG/revision/latest/scale-to-width-down/400?cb=20170101103142,background_url=https://media-exp1.licdn.com/dms/image/C4E1BAQEY67rO9YNpIw/company-background_10000/0?e=1592661600&v=beta&t=w0K0h9L18D6HieYM1giMf7TqKGne4LKqieuENS4RqDw,company_id=7d4cb366-aedf-476e-b3fc-61b9b1fc55eb} ``` Here is what I did: 1. I checked out the project - https://github.com/apache/camel-kafka-connector (with the change that you made) 2. Did **maven clean install** 3. Got the jar file **kafka-connector-0.8.0-SNAPSHOT.jar** created 4. Added it to my kafka connect image - this is how the jars look like. I have both **camel-kafka-connector-0.7.0.jar** and **camel-kafka-connector-0.8.0-SNAPSHOT.jar** ``` annotations-13.0.jar camel-core-engine-3.7.0.jar commons-codec-1.15.jar jackson-datatype-jdk8-2.10.2.jar lz4-java-1.7.1.jar apicurio-registry-common-1.3.1.Final.jar camel-core-languages-3.7.0.jar commons-compress-1.20.jar jackson-mapper-asl-1.9.13.jar medeia-validator-core-1.1.1.jar apicurio-registry-distro-connect-converter-1.3.0.Final.jar camel-core-model-3.7.0.jar commons-logging-1.2.jar jboss-jaxrs-api_2.1_spec-2.0.1.Final.jar medeia-validator-jackson-1.1.1.jar apicurio-registry-rest-client-1.3.1.Final.jar camel-core-processor-3.7.0.jar common-utils-5.5.0.jar jmespath-java-1.11.714.jar NOTICE.txt apicurio-registry-utils-converter-1.3.1.Final.jar camel-core-reifier-3.7.0.jar connect-json-2.6.0.jar joda-time-2.8.1.jar okhttp-3.14.9.jar apicurio-registry-utils-serde-1.3.1.Final.jar camel-direct-3.7.0.jar converter-jackson-2.9.0.jar kafka-avro-serializer-5.5.0.jar okio-1.17.2.jar avro-1.10.0.jar camel-jackson-3.7.0.jar httpclient-4.5.13.jar kafka-clients-2.6.0.jar protobuf-java-3.13.0.jar aws-java-sdk-core-1.11.714.jar camel-kafka-3.7.0.jar httpcore-4.4.14.jar kafka-connect-avro-converter-5.5.0.jar README.adoc aws-java-sdk-kms-1.11.714.jar camel-kafka-connector-0.7.0.jar ion-java-1.0.2.jar kafka-connect-avro-data-5.5.0.jar retrofit-2.9.0.jar aws-java-sdk-s3-1.11.714.jar camel-kafka-connector-0.8.0-SNAPSHOT.jar jackson-annotations-2.11.3.jar kafka-schema-registry-client-5.5.0.jar slf4j-api-1.7.30.jar camel-api-3.7.0.jar camel-main-3.7.0.jar jackson-core-2.11.3.jar kafka-schema-serializer-5.5.0.jar snappy-java-1.1.7.3.jar camel-aws-s3-3.7.0.jar camel-management-api-3.7.0.jar jackson-core-asl-1.9.13.jar kotlin-reflect-1.3.20.jar zstd-jni-1.4.4-7.jar camel-aws-s3-kafka-connector-0.7.0.jar camel-support-3.7.0.jar jackson-databind-2.11.3.jar kotlin-stdlib-1.3.20.jar camel-base-3.7.0.jar camel-util-3.7.0.jar jackson-dataformat-avro-2.11.3.jar kotlin-stdlib-common-1.3.20.jar camel-base-engine-3.7.0.jar common-config-5.5.0.jar jackson-dataformat-cbor-2.11.3.jar LICENSE.txt ``` 5. Deployed the kafka connect image to k8s 6. When I see the logs I can see that the update is processed ``` kubectl logs -f aws-connect-connect-76dc5478bd-tcjpr | grep SchemaAndStructToJsonTransform 2021-01-24 11:59:06,724 INFO Added plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2021-01-24 11:59:09,940 INFO Added alias 'SchemaAndStructToJsonTransform' to plugin 'org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] ``` 7. Upload the same kafka connector as the one from the original post 8. Then when the records started processing I saw the above exception Please let me know if I'm doing something wrong. Once again thanks for the help Regards Mihail Yordanov ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org