Suchergebnisse für Anfrage "apache-kafka"
Kafka Nicht erkannte VM-Option 'PrintGCDateStamps'
Ich habe Kafka auf einem Remote-Server installiert und als ich versuchte, @ auszuführ ~/kafka/bin/zookeeper-server-start.sh ~/kafka/config/zookeeper.propertiesUnd ich habe eine Fehlermeldung erhalten Unrecognized VM option ...
get Thema von kafka Nachricht in Funken
In unserem Spark-Streaming-Job lesen wir Nachrichten im Streaming von kafka. azu verwenden wir dasKafkaUtils.createDirectStream API, die @ zurückgiJavaPairInputDStreamfrom. Die Nachrichten werden von kafka (aus drei Themen - test1, test2, ...
JBOSS gibt org.apache.kafka.common.KafkaException aus: auth.conf kann nicht gelesen werden
Wenn ich in wildfly v 10 das war meines einfachen kafka-projekts (das gut als jar funktioniert) einsetze, erhalte ich eine ausnahmebedingung für die zookeeper-verbindung [1 [1]] 15:21:58,531 ERROR [org.jboss.msc.service.fail] (ServerService ...
Erstellen eines Themas für Apache Kafka 0.9 mit Java
Ich programmiere einen Client für die Arbeit mit kafka 0.9. Ich möchte wissen, wie man ein Thema erstellt. Diese Antwort:Wie erstelle ich ein Thema in Kafka mit ...
Ist Apache Kafka für die Verwendung als ungeordnete Task-Warteschlange geeignet?
Kafka teilt eingehende Nachrichten entsprechend der vom Produzenten zugewiesenen Partition in Partitionen auf. Nachrichten von Partitionen werden dann von Verbrauchern in verschiedenen Verbrauchergruppen konsumiert. Diese Architektur macht es ...
Kafka Avro Consumer mit Decoder-Problemen
Wenn ich versucht habe zu rennenKafka Consumer mit Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12] Über den Daten mit meinem jeweiligen Schema wird der Fehler "AvroRuntimeException: Fehlerhafte Daten. Länge ist negativ: -40" ...
Kafka Themen-API-Optionen für Nicht-Java-Sprachen erstellen
Während Sie ein Thema über Java oder Java-basierte Sprachen erstellen können (sieheHie [https://stackoverflow.com/questions/18225263/kafka-0-8-is-it-possible-to-create-topic-with-partition-and-replication-using-j] ), es scheint keinen sauberen ...
Wie konfiguriere ich die Protokollierung für Kafka-Produzenten?
Ich verwende Kafka Producer Client und ich habe keine log4j-Konfiguration in meinem Projekt. Wenn es läuft, druckt das Programm eine Menge Kafka Debug-Protokolle, die ich wirklich nicht möchte. Also, ich habe versucht, eine log4j.properties ...
Können mehrere Kafka-Konsumenten dieselbe Nachricht von der Partition lesen
Wir planen, einen Kafka-Consumer (Java) zu schreiben, der die Kafka-Warteschlange liest, um eine in der Nachricht enthaltene Aktion auszuführen. Wenn die Konsumenten unabhängig voneinander arbeiten, wird die Nachricht jeweils nur von einem ...