He estado revisando mucha documentación de Kafka para una aplicación Java en la que estoy trabajando. He intentado entrar en la sintaxis lambda introducida en Java 8, pero estoy un poco esquemático en ese terreno y no me siento muy seguro de que debería ser lo que uso hasta ahora.

Tengo un servicio Kafka / Zookeeper que se ejecuta sin problemas, y lo que quiero hacer es escribir un pequeño programa de ejemplo que, en función de la entrada, lo escriba, pero no haga un recuento de palabras, ya que hay tantos ejemplos.

En cuanto a los datos de muestra, obtendré una cadena de la siguiente estructura:

Datos de ejemplo

This a sample string containing some keywords such as GPS, GEO and maybe a little bit of ACC.

Pregunta

Quiero poder extraer las palabras clave de 3 letras e imprimirlas con unSystem.out.println. ¿Cómo obtengo una variable de cadena que contiene la entrada? Sé cómo aplicar expresiones regulares o incluso simplemente buscar a través de la cadena para obtener las palabras clave.

Código

public static void main(String[] args) {
    Properties props = new Properties();
    props.put(StreamsConfig.APPLICATION_ID_CONFIG, "app_id");
    props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "0:0:0:0:0:0:0:1:9092");
    props.put(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG, "0:0:0:0:0:0:0:1:2181");
    props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
    props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());

    final Serde<String> stringSerde = Serdes.String();

    KStreamBuilder builder = new KStreamBuilder();

    KStream<String, String> source = builder.stream(stringSerde, stringSerde, "in-stream");

    KafkaStreams streams = new KafkaStreams(builder, props);
    streams.start();

    //How do I assign the input from in-stream to the following variable?
    String variable = ?
}

Tengo al cuidador del zoológico, kafka, productor y consumidor corriendo todos conectados al mismo tema, así que básicamente quiero ver lo mismoString aparecer en todas las instancias (productor, consumidor y transmisión).