Hi Binh, to my knowledge ZeroMQ is no longer used in storm.
>From what you describe it seems there is a problem with acking/failing in your topology (could be downstream bolts do not ack or fail in all cases) and tuples get emitted until max pending is exhausted, then start failing when they hit the tuple timeout. This might help: https://storm.apache.org/releases/2.2.0/Guaranteeing-message-processing.html Jonas Am Fr., 15. Apr. 2022 um 23:08 Uhr schrieb Le, Binh T. < binh.t...@accenture.com>: > Hi, > > > > Can someone please help answer my question? We’re experiencing this issue > with storm 2.2.0 and wondering if it really is a ZeroMQ issue. > > > > Topology stops processing tuples after awhile > > Symptoms: > > - Processing works fine for awhile, and then suddenly stops and spout > tuples start failing en masse. > > Solutions: > > - This is a known issue with ZeroMQ 2.1.10. Downgrade to ZeroMQ 2.1.7. > > > > > > *From:* Le, Binh T. > *Sent:* Thursday, November 18, 2021 9:41 AM > *To:* user@storm.apache.org > *Subject:* ZeroMQ in Storm 2 > > > > Is ZeroMQ still used in Storm 2.x? If so, what version? According to > https://github.com/apache/storm/pull/9 and > https://issues.apache.org/jira/browse/STORM-2897, ZeroMQ has been > removed. However, they are still referenced in the following documentation: > > - > > http://storm.apache.org/releases/current/Installing-native-dependencies.html > - https://storm.apache.org/releases/2.2.0/Troubleshooting.html > > > > Is the documentation just outdated? > > ------------------------------ > > This message is for the designated recipient only and may contain > privileged, proprietary, or otherwise confidential information. If you have > received it in error, please notify the sender immediately and delete the > original. Any other use of the e-mail by you is prohibited. Where allowed > by local law, electronic communications with Accenture and its affiliates, > including e-mail and instant messaging (including content), may be scanned > by our systems for the purposes of information security and assessment of > internal compliance with Accenture policy. Your privacy is important to us. > Accenture uses your personal data only in compliance with data protection > laws. For further information on how Accenture processes your personal > data, please see our privacy statement at > https://www.accenture.com/us-en/privacy-policy. > > ______________________________________________________________________________________ > > www.accenture.com >
