`@KafkaListener`-Version des `spring-consumer` mit Business-Logik

[demos/kafka/training] / src / main / java / de / juplo / kafka / MessageHandler.java

diff --git a/src/main/java/de/juplo/kafka/MessageHandler.java b/src/main/java/de/juplo/kafka/MessageHandler.java
index 2f58f65..efd3f80 100644 (file)
--- a/src/main/java/de/juplo/kafka/MessageHandler.java
+++ b/src/main/java/de/juplo/kafka/MessageHandler.java
@@ -1,16 +1,19 @@
 package de.juplo.kafka;
 
-import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
 
-@RequiredArgsConstructor
 @Slf4j
+@Component
 public class MessageHandler
 {
-  private final String id;
-
-  private final AdderBusinessLogic adder;
+  @Value("${spring.kafka.client-id}")
+  private String id;
+  @Autowired
+  private AdderBusinessLogic adder;
 
 
   public void addNumber(