Я просматривал много документации Kafka для Java-приложения, над которым я работаю. Я попытался войти в лямбда-синтаксис, представленный в Java 8, но я немного отрывочен на этом основании и не чувствую себя слишком уверенным, что это должно быть то, что я использую до сих пор.

У меня Kafka / Zookeeper Service работает без каких-либо проблем, и я хочу написать небольшую примерную программу, которая на основе входных данных запишет ее, но не выполняет подсчет слов, так как примеров уже так много.

Что касается примеров данных, я получу строку следующей структуры:

Пример данных

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

Вопрос

Я хочу быть в состоянии извлечь 3-буквенные ключевые слова и распечатать их сSystem.out.println, Как получить строковую переменную, содержащую входные данные? Я знаю, как применять регулярные выражения или даже просто искать по строке, чтобы получить ключевые слова.

Код

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 = ?
}

У меня работает zookeeper, kafka, продюсер и потребитель, подключенные к одной и той же теме, поэтому я хочу в основном увидеть одно и то жеString появляются во всех экземплярах (производитель, потребитель и поток).