From e8d2d1a996fcdb39d95cc16813de0466b0661727 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 18 Jan 2025 16:11:38 +0100
Subject: [PATCH] TODO

---
 src/main/java/de/juplo/kafka/Application.java | 28 +++++++++++++++++++
 .../java/de/juplo/kafka/ExampleProducer.java  | 25 ++---------------
 2 files changed, 30 insertions(+), 23 deletions(-)
 create mode 100644 src/main/java/de/juplo/kafka/Application.java

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
new file mode 100644
index 00000000..bfc907de
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -0,0 +1,28 @@
+package de.juplo.kafka;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+
+@SpringBootApplication
+@EnableAsync
+public class Application
+{
+  @Autowired
+  ExampleProducer producer;
+
+  @EventListener(ApplicationReadyEvent.class)
+  public void onApplicationReady()
+  {
+    producer.run();
+  }
+
+  public static void main(String[] args)
+  {
+    SpringApplication.run(ExampleProducer.class, args);
+  }
+}
diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index db0b99eb..f928f0fe 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -2,32 +2,23 @@ package de.juplo.kafka;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.event.ApplicationReadyEvent;
-import org.springframework.context.event.EventListener;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.support.SendResult;
 import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.stereotype.Component;
 
 import java.util.concurrent.CompletableFuture;
 
 
 @Slf4j
-@EnableAsync
 // tag::supersimple[]
-@SpringBootApplication
+@Component
 public class ExampleProducer
 {
   @Autowired
   KafkaTemplate<String, String> kafkaTemplate;
 
-  // end::supersimple[]
   @Async
-  // tag::supersimple[]
   public void run()
   {
     for (int i = 0; true; i++)
@@ -55,17 +46,5 @@ public class ExampleProducer
       // tag::supersimple[]
     }
   }
-  // end::supersimple[]
-
-  @EventListener(ApplicationReadyEvent.class)
-  public void onApplicationReady() {
-    this.run();
-  }
-
-  // tag::supersimple[]
-  public static void main(String[] args)
-  {
-    SpringApplication.run(ExampleProducer.class, args);
-  }
 }
 // end::supersimple[]
-- 
2.20.1