oscerd commented on issue #1609: URL: https://github.com/apache/camel-kafka-connector/issues/1609#issuecomment-6632147055
Closing this as a usage question. The `camel-azure-storage-datalake-sink-kafka-connector` uploads the record value as-is (the Data Lake component reads the body as an `InputStream`), so the file contains exactly the bytes your SMT returns: return the value as `byte[]`, and for a real `.avro` file those bytes must be an Avro container file (header with the schema plus data blocks), not a single binary-encoded record. If the topic already holds the bytes you want to store, `value.converter=org.apache.kafka.connect.converters.ByteArrayConverter` passes them through without any SMT, and the file name can be set per record with a `CamelHeader.file` Kafka header. If the connector still alters the bytes on 4.22.x, please open a new issue with the connector config, the SMT code and a sample record; [email protected] and https://camel.zulipchat.com are good places for further questions. --- _Claude Code on behalf of Andrea Cosentino_ -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
