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 b08b209..fa2dacb 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);
         }
       }
     });