storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adrien Carreira <>
Subject Spout Questions
Date Mon, 02 May 2016 13:08:02 GMT
Hi there,

Dont't know if I'm on the right place.. But let's try.

I'm build a Topology, And I've a spout plugged on Redis.

My question is, when the topology is active, Why the nextTuple() method
isn't call when ack() method is called.

Meaning, I've about 10k acking message without a nextTuple() called...

So what going is : nextTuple is called to emit 30000k message, stops,
acking is called to ack all message without calling nextTuple to refeed the

What can be the problem ?

Thanks for your feedbacks and sorry for my bad english.

View raw message