Suchergebnisse für Anfrage "apache-kafka"
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 High Level Consumer holt alle Nachrichten vom Topic mit der Java API (Entspricht - von Anfang an)
Ich teste den Kafka High Level Consumer mit dem ConsumerGroupExample-Code von der Kafka-Site. Ich möchte alle vorhandenen Nachrichten zum Thema "Test" abrufen, die ich in der Kafka-Serverkonfiguration habe. In anderen Blogs ...
Problem beim Lesen von Nachrichten in Kafka neu ausgleichen
Ich versuche, Nachrichten zum Thema Kafka zu lesen, kann sie jedoch nicht lesen. Der Vorgang wird nach einiger Zeit abgebrochen, ohne dass Nachrichten gelesen werden. Hier ist der Ausgleichsfehler, den ich bekomme: [2014-03-21 10:10:53,215] ...
Gibt es eine einfache Möglichkeit, Kafka unter Windows zu installieren?
Ich versuche zu installierenKafka [http://kafka.apache.org/] Nachrichtenwarteschlange unter Windowszum PrüfenZweck (nicht für die Produktion: D). Ich habe nur diesen Artikel über die Installation von Apache Kafka 0.8 unter Windows ...
Wie erreicht man Mandantenfähigkeit im Kontext von Kafka und Sturm?
Was sind die Best Practices zum Erstellen einer mandantenfähigen App im Kontext von Kafka und Storm? Beispiel: Erstellen eines Themas für jeden Mandanten und Verwenden eines Auslaufs für mehrere Themen (mithilfe eines Platzhalters).
Apache Kafka - KafkaStream zum Thema / Partition
Ich schreibe Kafka Consumer für hochvolumige verteilte Hochgeschwindigkeitsanwendungen. Ich habe nur ein Thema, aber die Rate der eingehenden Nachrichten ist sehr hoch. Für diesen Anwendungsfall wäre es angemessen, mehrere Partitionen zu haben, ...
Ist Zookeeper ein Muss für Kafka?
In Kafka möchte ich nur einen einzelnen Broker, ein einzelnes Thema und eine einzelne Partition mit einem Produzenten und mehreren Konsumenten verwenden (wobei jeder Konsument eine eigene Kopie der Daten vom Broker erhält). Aus diesem Grund ...
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 ...
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 ...
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(); ...