X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FMessageHandler.java;h=efd3f8049b284b2d964056c4ee29f33d74850902;hb=refs%2Ftags%2Fspring-consumer--json--adder--kafkalistener--dlt---lvm-2-tage--easy-path;hp=2f58f6599102f6770ab6c9f07c112b241a420a95;hpb=059583e058173c3c7bd32ff1d16ba428d407931c;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/MessageHandler.java b/src/main/java/de/juplo/kafka/MessageHandler.java
index 2f58f65..efd3f80 100644
--- 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(