From: Kai Moritz Date: Wed, 2 Nov 2022 17:44:27 +0000 (+0100) Subject: WIP X-Git-Tag: simple-consumer--json-DEPRECATED~25 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=537873ff5ce5ca87aba7be46fd85f27181e3c4b3;p=demos%2Fkafka%2Ftraining WIP --- diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java index ab357c7..862c5f2 100644 --- a/src/main/java/de/juplo/kafka/Application.java +++ b/src/main/java/de/juplo/kafka/Application.java @@ -46,12 +46,6 @@ public class Application implements ApplicationRunner log.info("SimpleConsumer finished its work"); } - @Bean(destroyMethod = "close") - public Consumer kafkaConsumer(ConsumerFactory factory) - { - return factory.createConsumer(); - } - public static void main(String[] args) {