From 1dbad1e81eb5b335e72b3953e28108d34c70f86e Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 23 Nov 2024 10:26:30 +0100
Subject: [PATCH] =?utf8?q?`ConsumerHealthIndicator`=20refaktorisiert=20(Me?=
 =?utf8?q?thoden=20aufger=C3=A4umt)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../de/juplo/kafka/ConsumerHealthIndicator.java | 17 ++++++++---------
 1 file changed, 8 insertions(+), 9 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java b/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java
index dde95fcb..30fb7322 100644
--- a/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java
+++ b/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java
@@ -48,6 +48,13 @@ public class ConsumerHealthIndicator implements HealthIndicator
     return getHealthBuilder().build();
   }
 
+  private Health.Builder getHealthBuilder()
+  {
+    return rebalancingState == RebalancingState.RUNNING
+      ? new Health.Builder().up()
+      : new Health.Builder().status(rebalancingState.name());
+  }
+
 
   public void partitionsAssigned(Collection<TopicPartition> partitions)
   {
@@ -71,14 +78,6 @@ public class ConsumerHealthIndicator implements HealthIndicator
     updateAndRecordState(RebalancingState.FENCED, List.of());
   }
 
-
-  private Health.Builder getHealthBuilder()
-  {
-    return rebalancingState == RebalancingState.RUNNING
-      ? new Health.Builder().up()
-      : new Health.Builder().status(rebalancingState.name());
-  }
-
   private void updateAndRecordState(
     RebalancingState newRebalancingState,
     List<Partition> newAssignedPartitions)
@@ -98,6 +97,7 @@ public class ConsumerHealthIndicator implements HealthIndicator
     this.history = newHistory;
   }
 
+
   enum RebalancingState { STARTING, FENCED, REBALANCING, RUNNING }
 
   public record Partition(String topic, Integer partition) {}
@@ -106,7 +106,6 @@ public class ConsumerHealthIndicator implements HealthIndicator
     RebalancingState rebalancingState,
     List<Partition> assignedPartitions) {}
 
-
   private final static Comparator<Partition> partitionComparator = (tp1, tp2) ->
   {
     int result = tp1.topic().compareTo(tp2.topic());
-- 
2.20.1