oscerd commented on issue #1545: URL: https://github.com/apache/camel-kafka-connector/issues/1545#issuecomment-6632133223
Closing this as outdated: it was reported against 3.20.3, where the `aws-ddb-streams-source` Kamelet marshalled each stream record with `marshal: json`, which left an `InputStreamCache` in the record value. Since 4.4.2 the Kamelet converts each record to a JSON string with the `aws2-ddb:application-x-struct` data type instead, so with `camel-aws-ddb-streams-source-kafka-connector` 4.22.x and `StringConverter` the value should be the JSON text itself; if another connector still hands you a stream, the `org.apache.camel.kafkaconnector.transforms.CamelTypeConverterTransform$Value` SMT with `target.type=java.lang.String` converts it without a custom converter (the general case is tracked in #1543). Taking the record key from a payload field is not supported out of the box: `camel.source.camelMessageHeaderKey` reads a Camel header, and the DynamoDB Streams headers do not carry the item key, so that needs a custom SMT. If you still see an `InputStreamCache` value on 4.22.x, please open a new issue with your config and a sample record. --- _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]
