[STORM-2787] storm-kafka-client KafkaSpout should set 'initialized' flag independently of processing guarantees

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.2.0
• Fix Version/s: 2.0.0, 1.2.0
• Component/s: storm-kafka-client
• Labels: pull-request-available
• Epic Link: Release Apache Storm 1.2.0
• Assignee: Hugo Da Cruz Louro
• Reporter: Hugo Da Cruz Louro
• Created: 25/Oct/17 06:36
• Updated: 30/Oct/17 01:15
• Resolved: 30/Oct/17 01:15

Description

Currently the method

public void onPartitionsRevoked(Collection<TopicPartition> partitions) {

has the following condition

if (isAtLeastOnceProcessing() && initialized) {
                initialized = false;
                ...
}

initialized should be set to false independently of the processing guarantee

Issue Links

• links to: GitHub Pull Request #2387