Suchergebnisse für Anfrage "producer-consumer"
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 ...
Warten Sie und benachrichtigen Sie in Verbraucher- und Produzententhreads
Just begann Multi-Threading zu lernen. Ich habe 5 Produzenten und 2 Konsumenten in mehreren Threads. Grundsätzlich fügt dieses Programm 100 Elemente in die Warteschlange ein. Der Produzent beendet das Hinzufügen, wenn die Warteschlangengröße 100 ...
Verwalten der asynchronen Kommunikation: So überprüfen Sie die in einem anderen Thread empfangene Antwort
Ich habe einen Dispatcher-Thread und einen Listener-Thread. Wenn ich einen Befehl absende, möchte ich auf eine Antwort warten, bevor ich einen Folgebefehl sende. Außerdem muss ich die Antwort überprüfen, bevor ich mit dem zweiten Befehl ...
Consuming von Kafka fehlgeschlagen Iterator ist im Status fehlgeschlagen
Ich erhalte eine Ausnahme, während ich die Nachrichten von kafka konsumiere. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is ...
Wie funktioniert die Neuausrichtung der Verbraucher in Kafka?
Wenn ein neuer Verbraucher / Händler hinzugefügt wird oder ausfällt, löst Kafka einen Ausgleichsvorgang aus. Ist Kafka Rebalancing eine Blockieroperation? Werden Kafka-Verbraucher während eines Ausgleichsvorgangs gesperrt?
Wie aggregiere ich die Daten eines asynchronen Produzenten und schreibe sie in eine Datei?
Ich lerne etwas über asynchrone / Warte-Muster in C #. Momentan versuche ich ein Problem wie dieses zu lösen: Es gibt einen Hersteller (ein Hardwaregerät), der 1000 Pakete pro Sekunde generiert. Ich muss diese Daten in einer Datei ...
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 ...
Muss Monitor.Wait synchronisiert werden?
Ich habe eine generische Producer-Consumer-Warteschlange entwickelt, die von Monitor folgendermaßen gepulst wird: die Warteschlange: public void EnqueueTask(T task) { _workerQueue.Enqueue(task); Monitor.Pulse(_locker); }die ...
RabbitMQ C # API - ereignisbasierter Nachrichtenverbrauch
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; byte[] body = e.Body; Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); ...
Java: Hochleistungs-Message-Passing (Single-Producer / Single-Consumer)
Ich habe diese Frage anfangs gestelltHie [https://stackoverflow.com/questions/3367192/java-is-while-true-loop-in-a-thread-bad-whats-the-alternative] , aber mir ist klar geworden, dass es sich bei meiner Frage nicht um eine while-true-Schleife ...
Seite 1 von 2