Hi, I had some questions on the two properties - TOPOLOGY_MAX_SPOUT_PENDING and TOPOLOGY_MESSAGE_TIMEOUT_SECS
TOPOLOGY_MESSAGE_TIMEOUT_SECS 1. I set TOPOLOGY_MESSAGE_TIMEOUT_SECS to 1 implying that if a message emitted at spout is not acked in 1 second, then the message is replayed. What I see is that the message takes more than 3 seconds to complete (Time taken from spout emit to the time that the message is in DB), but I dont see a message timeout in logs nor I see the messages are getting replayed. For this test, I set TOPOLOGY_WORKERS to 2 and No. of ACKERS are 1. What am I missing? And what are the indication in the storm logs indicating that message is failed? I put a sysout in ack(...) and fail(...) and I dont see any fails. 2. TOPOLOGY_MAX_SPOUT_PENDING This setting lets you decide the max no. of unacked tuples in the topology. My question is - 1. If I have set this value to 100 and the spout gets 1000 messages, then what happens? Do the 900 messages get into a buffer? Thanks Kashyap
