ConfigurableApplicationContext context)
{
CounterStreamProcessor streamProcessor = new CounterStreamProcessor(
properties.getInputTopic(),
properties.getOutputTopic(),
propertyMap,
ConfigurableApplicationContext context)
{
CounterStreamProcessor streamProcessor = new CounterStreamProcessor(
properties.getInputTopic(),
properties.getOutputTopic(),
propertyMap,