From 2e0aa80786150fd9feea67f5d7d151bf5e178440 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 14 Dec 2024 12:55:35 +0100
Subject: [PATCH] =?utf8?q?Callback=20f=C3=BCr=20das=20Beenden=20der=20Spri?=
 =?utf8?q?ngBoot-App=20in=20eine=20Bean=20verwandelt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../de/juplo/kafka/ApplicationConfiguration.java     | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

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()
   {
-- 
2.20.1