From: Kai Moritz Date: Fri, 25 Mar 2022 09:11:07 +0000 (+0100) Subject: Obsoletes Klassen-Attribut entfernt X-Git-Tag: acks-KAPUTT-DEPRECATED~14 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=3e6afed388b02763eaf46b34cafa6e0c6b750621;p=demos%2Fkafka%2Ftraining Obsoletes Klassen-Attribut entfernt --- 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 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();