1 package de.juplo.kafka.wordcount.splitter;
3 import org.springframework.integration.annotation.Splitter;
4 import org.springframework.stereotype.Component;
6 import java.util.regex.Pattern;
10 public class MessageSplitter
12 final static Pattern PATTERN = Pattern.compile("\\W+");
14 @Splitter(inputChannel = "recordings", outputChannel = "words")
15 String[] split(String message)
17 return PATTERN.split(message);