From 1f11d4988dec0f07a1e15a0d963f51f5224422da Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Nov 2024 17:15:41 +0100
Subject: [PATCH] WIP:PartitionState -- ALIGN

---
 src/main/java/de/juplo/kafka/PartitionState.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/PartitionState.java b/src/main/java/de/juplo/kafka/PartitionState.java
index 0e66528..fa9bba9 100644
--- a/src/main/java/de/juplo/kafka/PartitionState.java
+++ b/src/main/java/de/juplo/kafka/PartitionState.java
@@ -16,7 +16,7 @@ import java.util.concurrent.Phaser;
 
 
 @Slf4j
-public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
+public class PartitionState implements Runnable, ConsumerRebalanceListener
 {
   private final String id;
   private final String topic;
@@ -39,7 +39,7 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
   private long consumed = 0;
 
 
-  public ExampleConsumer(
+  public PartitionState(
     String clientId,
     String topic,
     Consumer<String, String> consumer,
-- 
2.20.1