You need to limit the number of messages from the spout that are in flight and possibly increase the number of ackers.
On December 20, 2016 at 5:59:24 PM, Andrew Neilson ([email protected]) wrote: Are you calling ack() from within your topology? Make sure you read this carefully: http://storm.apache.org/releases/1.0.2/Guaranteeing-message-processing.html Sorry if your issue is deeper than this, but it would help to have more context. Andrew On Tue, Dec 20, 2016 at 3:23 AM [email protected] <[email protected]> wrote: Hi user, Does anyone know why it happen? The acker does not send message to spout, and almost all of the message is timeout. Joshua 2016-12-20 19:19:45
