WIP:PartitionState -- ALIGN

diff --git a/src/main/java/de/juplo/kafka/PartitionState.java b/src/main/java/de/juplo/kafka/PartitionState.java
index 0e66528..fa9bba9 100644 (file)
--- 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,