[STORM-2250] Kafka Spout Refactoring to Increase Modularity and Testability

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.0.2
• Fix Version/s: 2.0.0, 1.1.0
• Component/s: storm-kafka-client
• Epic Link: Release Apache Storm 1.1.0
• Assignee: Stig Rohde Døssing
• Reporter: Stig Rohde Døssing
• Created: 17/Dec/16 19:19
• Updated: 15/Feb/17 21:39
• Resolved: 15/Feb/17 21:39

Description

Per the discussion here https://github.com/apache/storm/pull/1826 the KafkaSpout class should be split up a bit, and the unit tests should be improved to use time simulation and not break encapsulation on the spout to test.

Issue Links

• links to: GitHub Pull Request #1832
• links to: GitHub Pull Request #1941