From: Kai Moritz Date: Fri, 4 Nov 2022 07:53:34 +0000 (+0100) Subject: WIP:StringDeserializer X-Git-Tag: simple-consumer--json-DEPRECATED~14 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ce7c6dbb4e23a2e4f047f2204b96a74578df1625;p=demos%2Fkafka%2Ftraining WIP:StringDeserializer --- diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 8849bf6..eab9aa9 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -38,7 +38,7 @@ public class ApplicationConfiguration } @Bean(destroyMethod = "close") - public Consumer kafkaConsumer(ConsumerFactory factory) + public Consumer kafkaConsumer(ConsumerFactory factory) { return factory.createConsumer(); }