Suchergebnisse für Anfrage "apache-kafka-streams"
Kafka Streaming Concurrency?
Ich habe einige grundlegende Kafka-Streaming-Codes, mit denen Datensätze aus einem Thema gelesen, verarbeitet und Datensätze zu einem anderen Thema ausgegeben werden. Wie geht Kafka-Streaming mit Parallelität um? Läuft alles in einem Thread? ...
Wie füge ich dem Kafka Streams DSL-Prozessor einen benutzerdefinierten StateStore hinzu?
Für eine meiner Kafka-Streams-Apps muss ich die Funktionen der DSL- und der Prozessor-API verwenden. Mein Streaming-App-Flow ist source -> selectKey -> filter -> aggregate (on a window) -> sink Nach der Aggregation muss ich eine SINGLE ...
Kafka Bestellung mehrerer Partitionen
Mir ist bekannt, dass es nicht möglich ist, mehrere Partitionen in Kafka zu bestellen, und dass die Partitionsreihenfolge nur für einen einzelnen Consumer innerhalb einer Gruppe (für eine einzelne Partition) garantiert ist. Aber ist es jetzt mit ...
Wie registriere ich einen zustandslosen Prozessor (der anscheinend auch einen StateStore benötigt)?
Ich erstelle eine Topologie und möchte @ verwend KStream.process () [https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#process(org.apache.kafka.streams.processor.ProcessorSupplier,%20java.lang.String...)] , um ...
Kafka KStream - AbstractProcessor mit einem Fenster verwenden
Ich hoffe, fenstergesteuerte Ausgabestapel von einem KStream zu gruppieren und in einen Sekundärspeicher zu schreiben. Ich hatte erwartet, @ zu seh.punctuate() wird ungefähr alle 30 Sekunden aufgerufen. Was ich stattdessen habe, wird ...
Kafka - Probleme mit TimestampExtractor
Ich benutzeorg.apache.kafka:kafka-streams:0.10.0.1 Ich versuche, mit einem zeitreihenbasierten Stream zu arbeiten, der anscheinend kein @ auslösKStream.Process() auslösen ("punctuate"). ...
Print Kafka Stream Input out to console?
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 ...
Warum verwendet Apache Kafka Streams RocksDB und wie kann das geändert werden?
Während der Untersuchung der neuen Funktionen in Apache Kafka 0.9 und 0.10 hatten wir KStreams und KTables verwendet. Interessanterweise verwendet Kafka RocksDB intern. SehenEinführung von Kafka Streams: Stream-Verarbeitung ...