Tag: apache-kafka-streams
Bezogen auf Apache Kafka ‚ s built-in-stream-processing-engine namens Kafka-Streams, was ist eine Java-Bibliothek für die Erstellung von verteilten stream-processing-apps mit Apache Kafka.
Fehler beim konstruieren kafka Verbraucher
1 Antworten
Es gibt durchaus ein paar Antworten zu diesem Thema aber nichts funktionierte. Ich versuche, führen Sie die folgenden streams-Prozessor. object simplestream extends App { val builder: KStreamBuilder = new KStreamBuilder val streamingConfig = { //ToDo - Move
Nicht in der Lage zu erstellen zustandsspeicher bei Kafka-streams
3 Antworten
Ich bin immer diese Fehlermeldung Failed to lock the state directory: /tmp/kafka-streams/string-monitor/0_1 beim erstellen von staatlichen laden in meiner kafka-streams-Anwendung. Hier ist die komplette stack-trace der Anwendung [2016-08-30 12:43:09,408] ERROR [StreamThread-1] User provided listener org.apache.kafka.streams.processor.internals.StreamThread$1 for group
Kafka-Streams mit Spring Boot
3 Antworten
Hey Leute, ich möchte die Arbeit mit Kafka-Streams Echtzeit-Verarbeitung in meine spring-boot-Projekt. Also ich brauche Kafka-Streams-Konfiguration oder möchte ich KStreams oder KTable, aber ich konnte nicht finden, etwa im internet. Habe ich Erzeuger und Verbraucher jetzt will
Unterschied zwischen Apache Samza und Apache Kafka-Streams (Fokus auf Parallelität und Kommunikation)
1 Antworten
In Samza und Kafka-Streams, Daten-stream-Verarbeitung erfolgt in einer Sequenz/graph (genannt "dataflow graph" in Samza und "Topologie" im Kafka-Streams) der Verarbeitung der Schritte (genannt "job" in Samza" und "Prozessor" in der Kafka-Streams). Ich nenne diese beiden Begriffe als
Akka Stream Kafka vs Kafka-Streams
3 Antworten
Ich arbeite derzeit mit Akka Stream Kafka Interaktion mit kafka und ich war wonderings, was waren die Unterschiede mit Kafka-Streams. Ich weiß, dass die Akka-basierten Ansatz implementiert die reaktive Spezifikationen und Griffe back-pressure-Funktionalität, die kafka Bäche scheint
Kafka - Dieser server ist nicht der Führer für das Thema-partition
2 Antworten
Habe ich zwei broker kafka 0.10.2.0 cluster.Replikations-Faktor ist 2. Ich bin mit 1.0.0 kafka-stream-Anwendung gegen diese Kafka. In meinem kafka-stream-Anwendung, Produzent config hat retries = 10 and retry.backoff.ms = 100 Läuft nach paar Minuten, die ich beobachtet