`ConsumerHealthIndicator` refaktorisiert (Methoden aufgeräumt)

diff --git a/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java b/src/main/java/de/juplo/kafka/ConsumerHealthIndicator.java
index dde95fc..30fb732 100644 (file)
--- 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());