projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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 ExecutorService executor;
private final String id;
private final String topic;
- private final String acks;
private final int throttleMs;
private final KafkaProducer<String, String> producer;
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.executor = executor;
this.id = clientId;
this.topic = topic;
- this.acks = acks;
this.throttleMs = throttleMs;
Properties props = new Properties();
this.throttleMs = throttleMs;
Properties props = new Properties();