Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Not A Problem
-
0.10.2
-
None
-
None
Description
Spout in the nextTuple may pull more than one kafka message, will remain in the _waitingToEmit, and then launch one by one, even if the TOPOLOGY_MAX_SPOUT_PENDING set to 1, when the first tuple is defeated, the bolt will still receive follow-up Message until _waitingToEmit is completely transmitted.
This and I think TOPOLOGY_MAX_SPOUT_PENDING is not the same meaning, I hope that the message can be strictly processed one by one, my topology worker number, spout and bolt parallelism are set to 1