Suchergebnisse für Anfrage "apache-kafka"
Warum ist die Leistung von Kafka-Verbrauchern langsam?
Ich habe ein einfaches Thema und einen einfachen Kafka-Konsumenten und -Produzenten mit der Standardkonfiguration. Das Programm ist sehr einfach, ich habe zwei Threads. Im Producer werden weiterhin 16-Byte-Daten gesendet. Und auf der ...
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 ...
Kafka: Kann nicht mehrere Stream-Konsumenten erstellen
Ich habe gerade Kafka 0.8 Beta 1 zum Laufen gebracht. Ich habe ein wirklich einfaches Beispiel zum Laufen gebracht. Das Problem ist, dass ich nur einen Messa...
Kafka Single Consumer Failure in einer Gruppe
Ich befinde mich in den ersten Phasen der Erkundung von Kafka, Version 0.8.1.1. Ich habe das Consumer Group Example mit mehreren Partitionen und der Verteilung von Nachrichten unter den Verbrauchern erfolgreich ausgeführt. Ein Testfall, den ich ...
Apache Kafka-Beispielfehler: Nach 3 Versuchen konnte keine Nachricht gesendet werden
Ich verwende dieses Beispiel eines Kafka-Produzenten, das auf seiner Website erwähnt wird Der Code: public class TestProducer { public static void main(String[] args) { long events = Long.parseLong(args[0]); Random rnd = new Random(); ...
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 ...
Verzögerung beim Konsumieren von Nachrichten in Apache Kafka
Ich benutze Kafka 0.8.0 und versuche, das unten genannte Szenario zu erreichen. JCA API (Dient als Produzent und sendet Daten an) -----> Consumer ------> HBase Ich sende jede Nachricht an den Verbraucher, sobald ich die Daten mit dem JCA-Client ...
Kafka: Schreiben eines benutzerdefinierten Serializers
Ich versuche mit Kafka 0.8.1 einen POC zu erstellen. Ich verwende meine eigene Java-Klasse als Kafka-Nachricht, die eine Reihe von String-Datentypen enthält. Ich kann die Standard-Serializer-Klasse oder die String-Serializer-Klasse, die mit der ...
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 ...