From: Kai Moritz Date: Sat, 2 Nov 2024 22:31:56 +0000 (+0100) Subject: WIP X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fconsumer%2Fspring-consumer--log-compaction--transactional;p=demos%2Fkafka%2Ftraining WIP --- diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 7883cf7..c05781e 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -66,7 +66,7 @@ public class ApplicationConfiguration } @Bean(destroyMethod = "") - KafkaProducer kafkaProducer(ApplicationProperties properties) + public KafkaProducer kafkaProducer(ApplicationProperties properties) { Properties props = new Properties(); props.put("bootstrap.servers", properties.getBootstrapServer()); @@ -86,7 +86,7 @@ public class ApplicationConfiguration } @Bean - Clock clock() + public Clock clock() { return Clock.systemDefaultZone(); }