use jsonDeserializer object instead of new one.

This commit is contained in:
Esmaeil Chitgar 2023-04-08 13:09:36 +04:30
parent f9b16c4101
commit 300212d781

View File

@ -37,7 +37,7 @@ public class KafkaConsumerConfig {
return new DefaultKafkaConsumerFactory<>(
consumerConfig(),
new StringDeserializer(),
new JsonDeserializer<>()
jsonDeserializer
);
}