From: Kai Moritz <kai@juplo.de>
Date: Sat, 14 Dec 2024 11:55:35 +0000 (+0100)
Subject: Callback für das Beenden der SpringBoot-App in eine Bean verwandelt
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=2e0aa80786150fd9feea67f5d7d151bf5e178440;p=demos%2Fkafka%2Ftraining

Callback für das Beenden der SpringBoot-App in eine Bean verwandelt
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 8308b002..ce12651c 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -26,7 +26,7 @@ public class ApplicationConfiguration
       RecordHandler<String, Long> recordHandler,
       ConsumerHealthIndicatorAwareRebalanceListener consumerHealthIndicatorAwareRebalanceListener,
       ApplicationProperties properties,
-      ConfigurableApplicationContext applicationContext)
+      Runnable closeCallback)
   {
     return
         new ExampleConsumer(
@@ -35,11 +35,11 @@ public class ApplicationConfiguration
             kafkaConsumer,
             recordHandler,
             consumerHealthIndicatorAwareRebalanceListener,
-            () -> applicationContext.close());
+            closeCallback);
   }
 
   @Bean
-  public RecordHandler<String, Long> recordHandler(ApplicationProperties properties)
+  public RecordHandler<String, Long> recordHandler()
   {
     return (topic, partition, offset, key, value) -> log.info("No-Ops Handler called for {}={}", key, value);
   }
@@ -56,6 +56,12 @@ public class ApplicationConfiguration
     return new ConsumerHealthIndicator(clock);
   }
 
+  @Bean
+  public Runnable closeCallback(ConfigurableApplicationContext applicationContext)
+  {
+    return () -> applicationContext.close();
+  }
+
   @Bean
   public Clock clock()
   {