oscerd commented on issue #1338: URL: https://github.com/apache/camel-kafka-connector/issues/1338#issuecomment-6632176487
Sorry this went unanswered. Closing this as a usage question, since it was reported against the 0.11.0 component-based connector, which no longer exists. The connector does not derive an Avro record schema from a JSON payload: the value reaches the converter as a plain string (or bytes), so AvroConverter registers a primitive `"string"` schema, and Schema Registry rejects it with 409 because the subject already holds your record schema. To publish Avro records, the value has to become a Kafka Connect `Struct` before the converter (for example through an SMT that parses the JSON against your schema); otherwise keep a String or JSON converter. If you hit a problem with camel-salesforce-source-kafka-connector on 4.22.x, please open a new issue with your configuration and the stack trace. --- _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]
