[KAFKA-801] Fix MessagesInPerSec mbean to count uncompressed message rate

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Fix Version/s: 0.8.0
• Component/s: core
• Labels: kafka-0.8 p2
• Assignee: Jun Rao
• Reporter: Neha Narkhede
• Created: 12/Mar/13 01:30
• Updated: 13/Mar/13 17:14
• Resolved: 13/Mar/13 17:11

Description

Today, BrokerTopicMetrics.MessagesInPerSec does shallow iteration and hence counts the number of compressed messages in every request. This does not make sense, we should count the number of uncompressed messages stored on the leader. Also, this metric makes sense only on the leader.