oscerd commented on issue #1720:
URL:
https://github.com/apache/camel-kafka-connector/issues/1720#issuecomment-6632124683
Closing this as answered, and sorry for the long wait.
`SchemaAndStructToJsonTransform` runs Kafka's `JsonConverter` with its default
`schemas.enable=true`, so the value it produces is a `{"schema": ...,
"payload": ...}` envelope, and the `aws-ddb-sink` Kamelet uses the top-level
JSON object as the DynamoDB item, which is why `order_id` is reported as
missing. Adding `"transforms.tojson.schemas.enable": "false"` makes the SMT
emit only the record fields (`{"order_id": 256795, ...}`); the SMT has not
changed since 2021, so this applies to your 3.20.3 deployment as well as to
`camel-aws-ddb-sink-kafka-connector` 4.22.x. If it still fails on 4.22.x with
that setting, please open a new issue with the connector version, config and
stack trace (usage questions are also welcome on [email protected] or
https://camel.zulipchat.com).
---
_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]
