In my topology, I read trigger messages from a Kafka queue. On receiving the trigger message, I need to emit around 4096 messages to a bolt. In the bolt, after some processing it will publish to another Kafka queue (another topology will consume this later).

I'm trying to set `TOPOLOGY_MAX_SPOUT_PENDING` parameter to throttle the number of messages going to bolt. But I see it is having no effect. Is it because I'm emitting all the tuples in one `nextTuple()` method? If so, what should be the work around?