From: Kai Moritz Date: Tue, 6 May 2025 18:48:08 +0000 (+0200) Subject: @PreDestroy ist bei passend benannter Methode nicht nötig X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=352d0778bb3f60a8150dcb97536772b3bcea91c4;p=demos%2Fkafka%2Ftraining @PreDestroy ist bei passend benannter Methode nicht nötig --- diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 9759913..68066fe 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -1,6 +1,5 @@ package de.juplo.kafka; -import jakarta.annotation.PreDestroy; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecord; @@ -99,7 +98,6 @@ public class ExampleConsumer implements Runnable log.info("{} - partition={}-{}, offset={}: {}={}", id, topic, partition, offset, key, value); } - @PreDestroy public void shutdown() { log.info("{} - Waking up the consumer", id);