davsclaus commented on a change in pull request #330:
URL: https://github.com/apache/camel-kamelets/pull/330#discussion_r645642001
##########
File path:
library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/serialization/InflightAvroSchemaResolver.java
##########
@@ -0,0 +1,21 @@
+package org.apache.camel.kamelets.utils.serialization;
+
+import com.fasterxml.jackson.core.FormatSchema;
+import com.fasterxml.jackson.dataformat.avro.AvroSchema;
+
+import org.apache.avro.Schema;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.jackson.SchemaResolver;
+
+public class InflightAvroSchemaResolver implements SchemaResolver {
+
+ @Override
+ public FormatSchema resolve(Exchange exchange) {
+ String schemaJson = (String) exchange.getProperty("schema");
Review comment:
Same as the previous PR, should these exchange properties be removed so
they dont leak out of the kamelet
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
