From 319d36866188f58738a2747ef6df3eba650261b0 Mon Sep 17 00:00:00 2001 From: EryneKL <97091460+EryneKL@users.noreply.github.com> Date: Thu, 2 Nov 2023 08:54:59 +0100 Subject: [PATCH] =?UTF-8?q?FIX=20:=20erreur=20lors=20de=20l'envoi=20du=20m?= =?UTF-8?q?essage=20endoftraitment=20=20=20=20=20=20-=20suppression=20de?= =?UTF-8?q?=20la=20config=20KafkaAvroSerializer=20et=20ajout=20de=20la=20c?= =?UTF-8?q?onfig=20StringSerializer=20du=20producerConfigs()=20dans=20Kafk?= =?UTF-8?q?aConfig.java=20=20=20=20=20=20-=20modification=20du=20param?= =?UTF-8?q?=C3=A8tre=20auto-register.schema=20dans=20application-dev.prope?= =?UTF-8?q?rties?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/fr/abes/bestppn/configuration/KafkaConfig.java | 4 +--- src/main/resources/application-dev.properties | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/src/main/java/fr/abes/bestppn/configuration/KafkaConfig.java b/src/main/java/fr/abes/bestppn/configuration/KafkaConfig.java index 138bb7b..d1d6595 100644 --- 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 producerConfigs() { Map 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 index 2ad9cd1..6b36a75 100644 --- 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=