Suchergebnisse für Anfrage "apache-kafka"
ERROR Fehler beim Senden der Nachricht an das Thema
Während ich eine Nachricht in kafka produziere, erhalte ich den folgenden Fehler: $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic nil_PF1_P1 hi hello [2016-07-19 17:06:34,542] ERROR Error when sending message to ...
Kafka 0.10 Java Client TimeoutException: Stapel mit 1 Datensatz (en) abgelaufen
Ich habe einen einzigen Knoten, Multi (3) Broker Zookeeper / Kafka-Setup. Ich verwende den Kafka 0.10 Java-Client. Ich habe folgenden einfachen Remote-Produzenten (auf einem anderen Server als Kafka) geschrieben (in dem Code, den ich durch MYIP ...
Wie man den Gruppennamen festlegt, wenn man Nachrichten in kafka über die Kommandozeile konsumiert
Eine Idee, wie Sie den Gruppennamen festlegen, wenn Sie Nachrichten in kafka über die Befehlszeile empfangen. Ich habe es mit dem folgenden Befehl versucht: bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic ...
Wie kann ein Offset im Spark Kafka-Direktstreaming manuell festgeschrieben werden?
Ich habe mich intensiv umgesehen, aber keine zufriedenstellende Antwort darauf gefunden. Vielleicht fehlt mir etwas. Bitte helfen Sie. Wir haben eine Spark-Streaming-Anwendung, die ein Kafka-Thema verwendet und die End-to-End-Verarbeitung ...
Kann keine Nachricht an kafka aus dem Dienst erzeugen, der im Docker ausgeführt wird
Ich habe einen Rest-Service im Docker-Container auf Port 5000, der verwendet wird, um eine Nachricht über ein kafka-Thema zu erstellen, dessen Docker-Container leer ist. Ich habe meinen Produzenten-Client mit den folgenden ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
ch habe bereits angefangen, Kafka zu lernen. Probieren Sie grundlegende Operationen aus. Ich habe an einem Punkt festgehalten, der sich mit den "Brokern" befasst. Meine Kafka läuft, aber wenn ich eine Partition erstellen möchte. from kafka ...
Verwenden Sie das Schema, um AVRO-Nachrichten mit Spark in DataFrame @ zu konvertiere
Gibt es eine Möglichkeit, ein Schema zum Konvertieren von @ zu verwende avro [/questions/tagged/avro] Nachrichten von kafka [/questions/tagged/kafka] mitFunk [/questions/tagged/spark] zu dataframe [/questions/tagged/dataframe]? Die Schemadatei ...
Wie läuft ein Offset für eine Apache Kafka-Verbrauchergruppe ab?
Ich habe einige Tests zu einem alten Thema durchgeführt, als ich merkwürdige Verhaltensweisen bemerkte. Beim Lesen von Kafkas Protokoll ist mir die Meldung aufgefallen, dass 8 abgelaufene Offsets entfernt wurden: [GroupCoordinator 1001]: ...
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 ...
Ausnahme beim Zugriff auf KafkaOffset über RDD
Ich habe einen Spark-Konsumenten, der von Kafka streamt. Ich versuche, Offsets für genau eine Semantik zu verwalten. Beim Zugriff auf den Offset wird jedoch die folgende Ausnahme ausgelöst: "java.lang.ClassCastException: ...