Refactor: Neue, klarere ``switch``-Syntax

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index e687a36f681f457ecb07a22f51fc1299a5c06844..d852f41aa4f037cb55e832f8fab05f0a08cdb46b 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -368,12 +368,8 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
         PartitionState partitionState = partitionStates[partition.partition()];
         switch (partitionState)
         {
-          case RESTORING, ASSIGNED:
-            stateUnassigned(partition.partition());
-            break;
-          default:
-          case UNASSIGNED:
-            log.warn("{} - partition {} in state {} was revoked!", id, partition, partitionState);
+          case RESTORING, ASSIGNED -> stateUnassigned(partition.partition());
+          case UNASSIGNED -> log.warn("{} - partition {} in state {} was revoked!", id, partition, partitionState);
         }
       }
     });