EndlessProducer arbeitet jetzt transaktional

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

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index bc617a8..d38b4ac 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -32,6 +32,7 @@ public class Application
             properties.getClientId(),
             properties.getTopic(),
             properties.getAcks(),
+            properties.getCommitIntervalMs(),
             properties.getThrottleMs());
 
     producer.start();