[KAFKA-136] A JMX bean that reports #message/sec in consumer

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7
• Fix Version/s: 0.7
• Assignee: Jun Rao
• Reporter: Jun Rao
• Created: 22/Sep/11 17:34
• Updated: 03/Oct/11 04:57
• Resolved: 03/Oct/11 04:57

Description

We need to add a jmx bean that shows # messages consumed by a consumer. The question is whether we want to break this down by topic. If not, the change is pretty straightforward by adding a counter in ConsumerIterator.