Andrea Cosentino

You're welcome to open a PR on camel-kamelets

https://github.com/apache/camel-kamelets/issues/1585

Use the following header "CamelHeader.CamelAzureStorageDataLakeDirectoryName" this one should be set I guess, but I'm not sure. We could add something to the Kamelet so you'll be able to specify the...

yes.

What is the version used? Also how are you specify the link to private key file?

The version of camel-kafka-connector I meant to ask. Also you need to prepend file:// if you use a local file

try with file:////Users/test/Downloads/test.ppk

Can you try with ``` key.converter: org.apache.kafka.connect.storage.StringConverter value.converter: org.apache.kafka.connect.converters.ByteArrayConverter ```

I need to reproduce this but I think we need to disable the stream caching here: https://github.com/apache/camel-kafka-connector/blob/main/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java#L143 with context.setStreamCaching(false); You can try to add this fix and rebuild the whole...

> @oscerd We get the following exception: `org.apache.kafka.connect.errors.DataException: ByteArrayConverter is not compatible with objects of type class org.apache.camel.converter.stream.InputStreamCache` The documentation is barebones because nobody is contributing a single line of...