Suchergebnisse für Anfrage "apache-kafka"
Apache Kafka mit High Level Consumer: Korrupte Nachrichten überspringen
Ich stehe vor einem Problem mit hochrangigen Kafka-Verbrauchern (0.8.2.0) - nachdem einige Datenmengen verbraucht wurden, stoppt einer unserer Verbraucher. Nach dem Neustart werden einige Meldungen verarbeitet und ohne Fehler / Ausnahme oder ...
Fehler beim Erstellen von Kafka-Themen - Replikationsfaktor größer als bei verfügbaren Brokern.
Ich versuche, Themen in Kafka zu erstellen, indem ich der Anleitung auf der Apache Kafka-Website über die Befehlszeile folge. Während der Ausführung des Befehls: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor ...
Kafka Fehler in E / A java.io.EOFException: null
Ich verwende Kafka 0.8.2.0 (Scala 2.10). In meinen Protokolldateien wird zeitweise die folgende Meldung angezeigt. Dies scheint ein Konnektivitätsproblem zu sein, aber ich führe beide in meinem localhost aus. Ist dies eine harmlose Warnmeldung ...
Verwendung des mqtt-Protokolls mit kafka als Nachrichtenbroker
Wie können wir das mqtt-Protokoll mit kafka als Nachrichtenbroker verwenden? Die Clients (Android / iOS / Desktop-Java-Apps usw.) erstellen und verarbeiten Nachrichten unter Verwendung der clientseitigen Bibliotheken von mqtt phao, die unter ...
Wie kann ich Kafka verwenden, um Protokolle länger im Logstash zu speichern?
Gegenwärtig benutze ich redis -> s3 -> elastic search -> kibana stack, um meine Protokolle weiterzuleiten und zu visualisieren. Aufgrund des großen Datenvolumens bei der elastischen Suche kann ich Protokolle jedoch bis zu 7 ...
Kafka 0.8.2.2 - Nachrichten können nicht veröffentlicht werden
Wir haben einen Java-Client für die Veröffentlichung von Nachrichten an kafka geschrieben. Der Code ist wie unten gezeigt Properties props = new ...
So löschen Sie ein Thema in Apache Kafka [duplizieren]
Diese Frage hat hier bereits eine Antwort: Thema in Kafka 0.8.1.1 löschen [/questions/24287900/delete-topic-in-kafka-0-8-1-1] 13 answersIch muss ein Thema in kafka-0.8.2.2.3 löschen. Ich habe den folgenden Befehl zum Löschen des ...
Konnte keine Anführer für Set finden ([TOPICNNAME, 0])) Wenn wir in Apache Saprk sind
Wir verwenden Apache Spark 1.5.1 und kafka_2.10-0.8.2.1 sowie die Kafka DirectStream-API, um mit Spark Daten von Kafka abzurufen. Wir haben die Themen in Kafka mit den folgenden Einstellungen erstellt ReplicationFactor: 1 und Replica: 1 Wenn ...
Ist kafka consumer 0.9 abwärtskompatibel?
Ist der kommende kafka consumer 0.9.x mit dem 0.8 Broker kompatibel? it anderen Worten: Es ist möglich, nur auf eine neue Consumer-Implementierung zu wechseln, ohne etwas anderes zu berühre
Kafka wie man von __consumer_offsets topic @ lie
Ich versuche herauszufinden, welche Offsets meine aktuellen High-Level-Konsumenten abarbeiten. Ich benutze Kafka 0.8.2.1, mitNei "offset.storage" in den server.properties von Kafka eingestellt - was meiner Meinung nach bedeutet, dass Offsets in ...