package de.juplo.kafka.wordcount.splitter;
+import org.springframework.integration.annotation.Splitter;
import org.springframework.stereotype.Component;
import java.util.regex.Pattern;
{
final static Pattern PATTERN = Pattern.compile("\\W+");
+ @Splitter(inputChannel = "recordings", outputChannel = "words")
String[] split(String message)
{
return PATTERN.split(message);