OuYang Liang created STORM-2880: ----------------------------------- Summary: Minor optimisation about kafka spout Key: STORM-2880 URL: https://issues.apache.org/jira/browse/STORM-2880 Project: Apache Storm Issue Type: Improvement Components: storm-kafka-client Affects Versions: 2.0.0 Reporter: OuYang Liang Assignee: OuYang Liang Priority: Minor Fix For: 2.0.0 Attachments: wx20180103-165...@2x.png
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. -- This message was sent by Atlassian JIRA (v6.4.14#64029)