Ich habe in der Kafka-Dokumentation nach einer Java-Anwendung gesucht, an der ich gerade arbeite. Ich habe versucht, mich mit der in Java 8 eingeführten Lambda-Syntax vertraut zu machen, bin aber in diesem Punkt etwas skizzenhaft und bin mir nicht sicher, ob es das ist, was ich derzeit verwende.

Ich habe einen Kafka / Zookeeper-Dienst, der ohne Probleme läuft, und ich möchte ein kleines Beispielprogramm schreiben, das es auf der Grundlage der Eingabe ausschreibt, aber keine Wortzählung durchführt, da es so viele Beispiele dafür gibt.

ie für Beispieldaten erhalte ich eine Zeichenfolge mit der folgenden Struktu

Beispieldaten

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

Frag

Ich möchte in der Lage sein, die 3 Buchstabenschlüsselwörter zu extrahieren und sie mit einem @ zu druckSystem.out.println. Wie erhalte ich eine String-Variable, die die Eingabe enthält? Ich kann reguläre Ausdrücke anwenden oder auch nur die Zeichenfolge durchsuchen, um die Schlüsselwörter zu erhalten.

Cod

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

Ich habe Zookeeper, Kafka, Produzent und Verbraucher, die alle mit demselben Thema beschäftigt sind, also möchte ich im Grunde dasselbe sehenString erscheint auf allen Instanzen (Producer, Consumer und Stream).