X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=c1bc0192e401788d1b60886095c6546c12d450e3;hb=2d25525ef70a90709edc48bd9542d1b08a2888a2;hp=b58295f29d5a68e586955a73f7a95efaed195fa7;hpb=bfddb34a846a27a477d97eaa4db9221afbd6dbba;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index b58295f..c1bc019 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -39,9 +39,7 @@ public class ApplicationConfiguration recordHandler, adderResults, stateRepository, - properties.getClientId(), - Clock.systemDefaultZone(), - properties.getCommitInterval()); + properties.getClientId()); } @Bean