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 ...

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 ...

Producer / Consumer-Threads, die eine Warteschlange verwenden

Ich möchte eine Art erstellenProducer/Consumer Threading-App. Aber ich bin mir nicht sicher, wie ich eine Warteschlange zwischen den beiden am besten implementieren kann. Also habe ich zwei Ideen (die beide völlig falsch sein könnten). Ich würde ...

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)); ...

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 ...

Implementieren des Blockierens von Lesevorgängen mithilfe von POSIX-Threads

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 ...

C # Produzent / Verbraucher

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?