From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Nov 2024 16:15:41 +0000 (+0100)
Subject: WIP:PartitionState -- ALIGN
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=1f11d4988dec0f07a1e15a0d963f51f5224422da;p=demos%2Fkafka%2Ftraining

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
--- 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,