oscerd commented on issue #1046: URL: https://github.com/apache/camel-kafka-connector/issues/1046#issuecomment-6632271486
Closing this as not planned. It has been idle since 2021. In 4.22.x, connectors that need structured input, such as the SQL ones (for example camel-postgresql-sink-kafka-connector), are generated from Kamelets that unmarshal a JSON payload themselves before building the query. For records that arrive as a Kafka Connect Struct (Avro, or JSON with schemas), the bundled `org.apache.camel.kafkaconnector.transforms.SchemaAndStructToJsonTransform` SMT turns them into JSON, which covers the case described here. If a 4.22.x connector really needs a Map body that can't be produced this way, please open a new issue with the connector, configuration and error. --- _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]
