[STORM-1379] Removed Redundant Structure

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.10.0, 0.9.4, 0.9.5, 0.9.6
• Fix Version/s: 1.0.0
• Component/s: storm-kafka
• Environment: CentOS 6 JDK1.7.0_75
• Assignee: darion yaphet
• Reporter: darion yaphet
• Created: 08/Dec/15 10:51
• Updated: 26/Jan/16 15:45
• Resolved: 08/Jan/16 16:40

Description

Storm KafkaSpout have a static class MessageAndRealOffset which is same with Kafka API 's kafka.message.MessageAndOffset . So I have remove MessageAndRealOffset and replace with MessageAndOffset