counter: 1.1.9 - Refactored creation of `Properties` as a separate bean

[demos/kafka/wordcount] / src / main / java / de / juplo / kafka / wordcount / counter / CounterApplication.java

diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplication.java b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplication.java
index 20cb4d2..31086ca 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplication.java
+++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplication.java
@@ -24,12 +24,8 @@ import static org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.St
 @Slf4j
 public class CounterApplication
 {
-       @Bean(initMethod = "start", destroyMethod = "stop")
-       public CounterStreamProcessor streamProcessor(
-                       CounterApplicationProperties properties,
-                       KeyValueBytesStoreSupplier storeSupplier,
-                       ObjectMapper objectMapper,
-                       ConfigurableApplicationContext context)
+       @Bean
+       public Properties propertyMap(CounterApplicationProperties properties)
        {
                Properties propertyMap = new Properties();
 
@@ -44,6 +40,17 @@ public class CounterApplication
                        propertyMap.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, properties.getCacheMaxBytes());
                propertyMap.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
 
+               return propertyMap;
+       }
+
+       @Bean(initMethod = "start", destroyMethod = "stop")
+       public CounterStreamProcessor streamProcessor(
+                       CounterApplicationProperties properties,
+                       Properties propertyMap,
+                       KeyValueBytesStoreSupplier storeSupplier,
+                       ObjectMapper objectMapper,
+                       ConfigurableApplicationContext context)
+       {
                CounterStreamProcessor streamProcessor = new CounterStreamProcessor(
                                properties.getInputTopic(),
                                properties.getOutputTopic(),