OUT,
Stores.inMemoryKeyValueStore("TOPOLOGY-TEST"));
- CounterApplicationConfiguriation config =
+ CounterApplicationConfiguriation applicationConfiguriation =
new CounterApplicationConfiguriation();
- Properties properties =
- config.propertyMap(new CounterApplicationProperties());
+ Properties streamProcessorProperties =
+ applicationConfiguriation.streamProcessorProperties(new CounterApplicationProperties());
- TopologyTestDriver testDriver = new TopologyTestDriver(topology, properties);
+ TopologyTestDriver testDriver = new TopologyTestDriver(topology, streamProcessorProperties);
TestInputTopic<String, String> in = testDriver.createInputTopic(
IN,