Merge pull request #27 from abes-esr/FIX-error-to-sent-endoftraitment…

…-message FIX : erreur lors de l'envoi du message endoftraitment
abes-esr · Nov 2, 2023 · 5e79c43 · 5e79c43
2 parents 59c8e2b + 319d368
commit 5e79c43
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/main/java/fr/abes/bestppn/configuration/KafkaConfig.java b/src/main/java/fr/abes/bestppn/configuration/KafkaConfig.java
@@ -75,9 +75,7 @@ public Map<String, Object> producerConfigs() {
         Map<String, Object> props = new HashMap<>();
         props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
-        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
-        props.put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, registryUrl);
-        props.put(KafkaAvroSerializerConfig.AUTO_REGISTER_SCHEMAS, autoRegisterSchema);
+        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
         return props;
     }
 

diff --git a/src/main/resources/application-dev.properties b/src/main/resources/application-dev.properties
@@ -2,7 +2,7 @@
 spring.kafka.producer.bootstrap-servers=
 spring.kafka.consumer.bootstrap-servers=
 spring.kafka.registry.url=
-spring.kafka.auto.register.schema=true
+spring.kafka.auto.register.schema=false
 
 url.onlineId2Ppn=
 url.printId2Ppn=