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:
[email protected]
