From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Apr 2022 20:30:01 +0000 (+0200)
Subject: /status gibt auch den `username` des Clients aus
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=42563fe7328e387b3c343a9b6402ee5142950515;p=demos%2Fkafka%2Ftraining

/status gibt auch den `username` des Clients aus
---

diff --git a/src/main/java/de/juplo/kafka/RestClient.java b/src/main/java/de/juplo/kafka/RestClient.java
index 689d672..38fd655 100644
--- a/src/main/java/de/juplo/kafka/RestClient.java
+++ b/src/main/java/de/juplo/kafka/RestClient.java
@@ -122,24 +122,27 @@ public class RestClient implements Callable<Long>
 
   public synchronized Status getStatus()
   {
-    return new Status(running, pending, offsets, failures);
+    return new Status(username, running, pending, offsets, failures);
   }
 
 
   @Getter
   public class Status
   {
+    String username;
     boolean running;
     Set<Long> pending;
     Map<Integer, Long> offsets;
     List<RestFailure> failures;
 
     private Status(
+        String username,
         boolean running,
         Set<Long> pending,
         Map<Integer, Long> offsets,
         List<RestFailure> failures)
     {
+      this.username = username;
       this.running = running;
       guarded(() ->
       {