In my storm topology i am reading message from queue and sending to s3 and
mysql.
Even though i send one message , topology shows emit count and transferred
count as 20. Any idea why 20 is coming.
Spout

 spoutOutputCollector.emit(new Values(message), message.getReceiptHandle());

Bolt

 outputCollector.emit(tuple,new Values(fullMessage));

            outputCollector.ack(tuple);

Reply via email to