[STORM-2880] Minor optimisation about kafka spout

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 2.0.0
• Component/s: storm-kafka-client
• Labels: pull-request-available
• Assignee: OuYang Liang
• Reporter: OuYang Liang
• Due: 03/Jan/18
• Created: 03/Jan/18 08:52
• Updated: 27/Apr/18 19:31
• Resolved: 27/Apr/18 19:31

Description

Based on the single responsibility principle, method isAtLeastOnceProcessing() should reside in KafkaSpoutConfig rather than KafkaSpout. This patch removes the dependency of KafkaSpoutConfig.ProcessingGuarantee from KafkaSpout.

Issue Links

• links to: GitHub Pull Request #2494