From ea97dff1e6491c12aabe723be315b239f5e35ba5 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 2 Nov 2022 18:53:06 +0100 Subject: [PATCH] WIP:StringDeserializer --- src/main/resources/application.yml | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index c2cb792..ae7aae8 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -30,13 +30,10 @@ spring: auto-offset-reset: earliest auto-commit-interval: 5s key-deserializer: org.apache.kafka.common.serialization.StringDeserializer - value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer + value-deserializer: org.springframework.kafka.support.serializer.StringDeserializer properties: partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor metadata.max.age.ms: 1000 - spring.json.type.mapping: > - ADD:de.juplo.kafka.MessageAddNumber, - CALC:de.juplo.kafka.MessageCalculateSum logging: level: root: INFO -- 2.20.1