X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=3b90388567a9e9060d0939ae3f043ea9969d1cbc;hb=3e6afed388b02763eaf46b34cafa6e0c6b750621;hp=43b0e41e7625364083aa1ae6157adb34799dda74;hpb=91fd1b3b5e55e78709934e44c42f32419dfb9ba8;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java
index 43b0e41..3b90388 100644
--- 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();