Gibt es in einer Apache Storm-Topologie eine interne Warteschlange zwischen einer Tülle und einer Schraube?

Question

Um einen bestimmt RabbitMQ Message Broker Implementierung, konform zu sein ist es kritisch, dass der Auslauf verbrauchen und so schnell wie möglich die gesendeten Nachrichten bestätigen.

Die Spezifikationen der Message Broker-Instanz bestehen auf der Tatsache, dass der Verbraucher eine Warteschlange in den Speicher implementieren muss, um die Bestätigung im Falle einer langsamen Verarbeitungszeit nicht zu verzögern.

Gibt es eine solche implizite Warteschlange zwischen einem Auslauf und einer Schraube? Muss ich eine In-Memory-Warteschlange innerhalb der Schraube implementieren?

Answer 1

Es gibt eine Warteschlange zwischen Ausgüssen und Schrauben, as stated here.

Wenn Ihnen das nicht weiterhilft, können Sie einen internen Puffer in der Ausgabe erstellen und bestätigen, sobald Sie das Tupel in diesen internen Puffer einfügen.