Suchergebnisse für Anfrage "apache-kafka"
Wann und wie wird ein zum Löschen markiertes Thema endgültig entfernt?
Ich habe den Befehl zum Löschen eines Themas erteilt: ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts Es schien eine glückliche Antwort zu geben: [2014-05-31 20:58:10,112] INFO zookeeper state changed ...
Fehler beim Schreiben von Versatzdaten an den Tierpfleger im Kafka-Sturm
Ich habe einen Sturmcluster eingerichtet, um Echtzeit - Trends und andere Statistiken zu berechnen. Ich habe jedoch einige Probleme, die "Wiederherstellungs" - Funktion in dieses Projekt einzuführen, indem ich den Offset zulasse, der zuletzt von ...
Beim Neustart eines Kafka (Python) -Konsumenten werden alle Nachrichten in der Warteschlange erneut verarbeitet
Ich benutze Kafka 0.8.1 und Kafka Python-0.9.0. In meinem Setup habe ich 2 Kafka-Broker eingerichtet. Wenn ich meinen kafka-Consumer starte, kann ich sehen, dass er Nachrichten aus der Warteschlange abruft und die Offsets für beide Broker ...
So erhalten Sie eine Themenliste vom kafka-Server in Java
ich benutzekafka 0.8 Version und sehr neu. Ich möchte die Liste der Themen kennen, die in erstellt wurdenkafka server zusammen mit seinen Metadaten. Gibt es eine API, um dies herauszufinden? Grundsätzlich muss ich einen Java-Konsumenten ...
Spark Kafka Streaming Issue
Ich benutze Maven Ich habe die folgenden Abhängigkeiten hinzugefügt <dependency> <!-- Spark dependency --> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming_2.10</artifactId> <version>1.1.0</version> </dependency> <dependency> ...
Wie implementiere ich die Deserialisierung in kafka consumer mit scala?
Ich habe die folgende Zeile im Code meines Kafka-Verbrauchers. val lines = KafkaUtils.createStream(ssc, zkQuorum, group, topicpMap).map(_._2) Wie deserialisiere ich diesen Stream "lines" in ein Originalobjekt? Die Serialisierbarkeit wurde im ...
Erstelle mehrere Consumer in Kafka in der Kommandozeile
Ich bin neu in Kafka. Als ich das Schnellstart-Beispiel in der Befehlszeile ausführte, stellte ich fest, dass ich nicht mehrere Consumer in der Befehlszeile erstellen kann. Bedingung Ich habe ein Thema namens test mit 3 Partitionen erstellt ...
Wie erstelle ich ein Thema in Kafka mit Java?
Ich möchte ein Thema in Kafka (kafka_2.8.0-0.8.1.1) über Java erstellen. Es funktioniert einwandfrei, wenn ich ein Thema in der Eingabeaufforderung erstelle und wenn ich eine Nachricht über Java API schiebe. Aber ich möchte ein Thema mit Java API ...
Wie funktioniert die Neuausrichtung der Verbraucher in Kafka?
Wenn ein neuer Verbraucher / Händler hinzugefügt wird oder ausfällt, löst Kafka einen Ausgleichsvorgang aus. Ist Kafka Rebalancing eine Blockieroperation? Werden Kafka-Verbraucher während eines Ausgleichsvorgangs gesperrt?
Anzahl von Commits und Offset in jeder Partition eines Kafka-Themas
So finden Sie die Anzahl der Festschreibungen und den aktuellen Versatz in jeder Partition einesbekann kafka Thema. Ich benutze kafka v0.8.1.1