[STORM-2915] How could I to get the fail Number in Bolt When I use Kafka Spout

• Type: New Feature
• Status: Closed
• Priority: Minor
• Resolution: Invalid
• Affects Version/s: 1.0.2, 1.1.0, 1.0.3, 1.0.4, 1.1.1, 1.0.5
• Component/s: storm-kafka-client
• Assignee: Unassigned
• Reporter: Gergo Hong
• Created: 28/Jan/18 09:22
• Updated: 25/Jun/18 02:12
• Resolved: 25/Jun/18 02:12

Description

I want to get fail num in bolt , how could  I  to get it? 

if  fail it  retry, I see This 

if (!isScheduled || retryService.isReady(msgId)) {
final String stream = tuple instanceof KafkaTuple ? ((KafkaTuple) tuple).getStream() : Utils.DEFAULT_STREAM_ID;

if (!isAtLeastOnceProcessing()) {
if (kafkaSpoutConfig.isTupleTrackingEnforced()) {
collector.emit(stream, tuple, msgId);
LOG.trace("Emitted tuple [{}] for record [{}] with msgId [{}]", tuple, record, msgId);
} else {
collector.emit(stream, tuple);
LOG.trace("Emitted tuple [{}] for record [{}]", tuple, record);
}
} else {
emitted.add(msgId);
offsetManagers.get(tp).addToEmitMsgs(msgId.offset());
if (isScheduled)

{ // Was scheduled for retry and re-emitted, so remove from schedule. retryService.remove(msgId); }

collector.emit(stream, tuple, msgId);
tupleListener.onEmit(tuple, msgId);
LOG.trace("Emitted tuple [{}] for record [{}] with msgId [{}]", tuple, record, msgId);
}
return true;
}