
topology.max.spout.pending allows to limit the number of concurrent entries sent from spout to worker(s). However, this requires the usage of a unique id when sending messages (emit). Change-Id: I907a4574b80e7c3347ba6a9f12c7836767dc3dd7 Story: 2005471 Task: 30550