+ return propertyMap;
+ }
+
+ @Bean(initMethod = "start", destroyMethod = "stop")
+ public CounterStreamProcessor streamProcessor(
+ CounterApplicationProperties properties,
+ Properties propertyMap,
+ KeyValueBytesStoreSupplier storeSupplier,
+ ObjectMapper objectMapper,
+ ConfigurableApplicationContext context)
+ {