import org.springframework.util.MultiValueMap;
import java.util.Map;
-import java.util.stream.Collectors;
import static de.juplo.kafka.wordcount.counter.CounterApplicationConfiguriation.serializationConfig;
import static de.juplo.kafka.wordcount.counter.CounterStreamProcessor.STORE_NAME;
private static String typeMappingsConfig()
{
- return typeMappings()
- .entrySet()
- .stream()
- .map(entry -> entry.getKey() + ":" + entry.getValue().getName())
- .collect(Collectors.joining(","));
- }
-
- private static Map<String, Class> typeMappings()
- {
- return Map.of(
- "word", TestOutputWord.class,
- "counter", TestOutputWordCounter.class);
+ return CounterStreamProcessor.typeMappingsConfig(TestOutputWord.class, TestOutputWordCounter.class);
}
}