/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 (file)
--- 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(() ->
       {