Suchergebnisse für Anfrage "apache-kafka"
Was sind die Einschränkungen für Apache Kafka-Themennamen?
Ich habe gerade versucht, ein Kafka-Thema zu erstellen"user:created" und sah diesen Fehler in Kafka-Protokollen:Invalid character ':' in value part of property. Ich habe gegoogelt und festgestellt, dass es in einer Mailingliste um das Verachten ...
Kafka: Ändere die Anzahl der Partitionen für ein bestimmtes Thema mit java
Ich bin neu bei Kafka und arbeite mit dem neuen KafkaProducer und KafkaConsumer, Version: 0.9.0.1. Ist es in Java möglich, die Anzahl der Partitionen für ein bestimmtes Thema zu ändern / zu aktualisieren, nachdem es erstellt wurde. Ich benutze ...
Streamparse wordcount example
Ich wollte Apache Storm verwenden, um von Kafka zu streamen. Ich fühle mich mit Python wohler und habe mich für streamparse entschieden https: //github.com/Parsely/streampars [https://github.com/Parsely/streamparse]). Das Beispiel für die ...
Kafka 0.9.0.1 Java Consumer bleibt in awaitMetadataUpdate () hängen
Ich versuche, einen einfachen Kafka-Konsumenten mit der Java-API v0.9.0.1 zum Laufen zu bringen. Der von mir verwendete Kafka-Server ist ein Docker-Container, auf dem auch Version 0.9.0.1 ausgeführt wird. Unten ist der Verbrauchercode: public ...
Kafka-Themenpartitionen für Spark-Streaming
Ich habe einige Anwendungsfälle, die ich genauer erläutern möchte, zum Thema Kafka-Partitionierung -> Verwendung von Spark-Streaming-Ressourcen. Ich verwende den Spark-Standalone-Modus, daher sind nur die Einstellungen "Gesamtanzahl der ...
Kafka-Themen und Partitionen verstehen
Ich fange an, Kafka für Unternehmenslösungszwecke zu lernen. ährend meiner Lesungen kamen mir einige Fragen in den Sin Wenn ein Produzent eine Nachricht erstellt - wird das @ angegebThem Es möchte die Nachricht an senden, ist das richtig? ...
Kafka-Thema in einem Spark-Batch-Job lesen
Ich schreibe einen Spark-Stapeljob (v1.6.0), der aus einem Kafka-Thema liest. Dafür kann ichorg.apache.spark.streaming.kafka.KafkaUtils#createRDD Ich muss jedoch die Offsets für alle Partitionen festlegen und sie auch irgendwo speichern (ZK? ...
Error: Hauptklasse config.zookeeper.properties konnte nicht gefunden oder geladen werden
Ich versuche, mit Apache Kafka ein Beispiel für eine Producer-Consumer-Anwendung auszuführen. Ich habe es von @ heruntergeladhttps: //www.apache.org/dyn/closer.cgi? path = / kafka / 0.10.0.0 ...
Warum kann ich session.timeout.ms nicht erhöhen
Ich möchte erhöhensession.timeout.ms, um eine längere Zeit für die Verarbeitung der zwischen @ empfangenen Nachrichten zu gewährepoll() Anrufe. Wenn ich jedoch @ ändesession.timeout.ms auf einen höheren Wert als 30000, es kann ...