diff --git a/kafka-avro/pom.xml b/kafka-avro/pom.xml index 47745d78..79034497 100644 --- a/kafka-avro/pom.xml +++ b/kafka-avro/pom.xml @@ -62,6 +62,13 @@ pom import + + + + org.apache.avro + avro + ${avro-version} + diff --git a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroDeserializer.java b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroDeserializer.java index 30adb0ab..c2f24c38 100644 --- a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroDeserializer.java +++ b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroDeserializer.java @@ -20,7 +20,6 @@ import java.util.List; import java.util.Map; -import io.confluent.common.config.ConfigException; import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; import io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer; import io.confluent.kafka.serializers.KafkaAvroDeserializerConfig; @@ -37,16 +36,10 @@ public void configure(KafkaAvroDeserializerConfig config) { LOG.info("ENTER CustomKafkaAvroDeserializer : configure method "); LOG.info("ENTER CustomKafkaAvroDeserializer : SCHEMA_REGISTRY_URL " + SCHEMA_REGISTRY_URL); - try { + final List schemas = Collections.singletonList(SCHEMA_REGISTRY_URL); + this.schemaRegistry = new CachedSchemaRegistryClient(schemas, Integer.MAX_VALUE); + this.useSpecificAvroReader = true; - final List schemas = Collections.singletonList(SCHEMA_REGISTRY_URL); - this.schemaRegistry = new CachedSchemaRegistryClient(schemas, Integer.MAX_VALUE); - this.useSpecificAvroReader = true; - - } catch (ConfigException e) { - e.printStackTrace(); - throw new org.apache.kafka.common.config.ConfigException(e.getMessage()); - } LOG.info("EXIT CustomKafkaAvroDeserializer : configure method "); } diff --git a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroSerializer.java b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroSerializer.java index 8b30404a..816e34a2 100644 --- a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroSerializer.java +++ b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/CustomKafkaAvroSerializer.java @@ -20,9 +20,10 @@ import java.util.List; import java.util.Map; +import io.confluent.kafka.schemaregistry.avro.AvroSchema; +import io.confluent.kafka.schemaregistry.avro.AvroSchemaUtils; import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient; import io.confluent.kafka.serializers.AbstractKafkaAvroSerializer; -import io.confluent.kafka.serializers.AvroSchemaUtils; import io.confluent.kafka.serializers.KafkaAvroSerializerConfig; import org.apache.kafka.common.config.ConfigException; import org.apache.kafka.common.serialization.Serializer; @@ -46,8 +47,9 @@ public byte[] serialize(String topic, Object record) { LOG.info("****************serialize*******************************"); LOG.info("Serialize method: topic " + topic); LOG.info("Serialize method: byte " + record); + AvroSchema schema = new AvroSchema(AvroSchemaUtils.getSchema(record)); return serializeImpl( - getSubjectName(topic, isKey, record, AvroSchemaUtils.getSchema(record)), record); + getSubjectName(topic, isKey, record, schema), record, schema); } @Override diff --git a/master/pom.xml b/master/pom.xml index bc5d9203..e1a19085 100644 --- a/master/pom.xml +++ b/master/pom.xml @@ -117,7 +117,6 @@ openshift openshift - registry.access.redhat.com/ubi8/openjdk-17 diff --git a/pom.xml b/pom.xml index 21b5682c..32b1c89c 100644 --- a/pom.xml +++ b/pom.xml @@ -100,14 +100,13 @@ 4.9.0-SNAPSHOT false - 4.0.1 - 1.14.0 - 5.2.2 - 3.5.11 - 1.19.8 - 2.3 - 2.6.7 - 2.31.0 + 1.17.0 + registry.access.redhat.com/ubi9/openjdk-17:latest + 7.1.1 + 3.7.0 + 1.20.4 + 2.5.1 + 2.38.0 @@ -136,20 +135,6 @@ - - - - - javax.servlet - javax.servlet-api - ${javax.servlet.api.version} - - - - diff --git a/saga/pom.xml b/saga/pom.xml index 494d1a78..1b91f1ae 100644 --- a/saga/pom.xml +++ b/saga/pom.xml @@ -37,7 +37,6 @@ UTF-8 UTF-8 - registry.access.redhat.com/ubi8/openjdk-17