From 42563fe7328e387b3c343a9b6402ee5142950515 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Apr 2022 22:30:01 +0200
Subject: [PATCH] /status gibt auch den `username` des Clients aus

---
 src/main/java/de/juplo/kafka/RestClient.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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(() ->
       {
-- 
2.20.1