Obsoletes Klassen-Attribut entfernt

[demos/kafka/training] / src / main / java / de / juplo / kafka / EndlessProducer.java

diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java
index 43b0e41..3b90388 100644 (file)
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -18,7 +18,6 @@ public class EndlessProducer implements Runnable
   private final ExecutorService executor;
   private final String id;
   private final String topic;
-  private final String acks;
   private final int throttleMs;
   private final KafkaProducer<String, String> producer;
 
@@ -38,7 +37,6 @@ public class EndlessProducer implements Runnable
     this.executor = executor;
     this.id = clientId;
     this.topic = topic;
-    this.acks = acks;
     this.throttleMs = throttleMs;
 
     Properties props = new Properties();