Hugo Louro created STORM-2787: --------------------------------- Summary: storm-kafka-client should set initialized flag independently of processing guarantees Key: STORM-2787 URL: https://issues.apache.org/jira/browse/STORM-2787 Project: Apache Storm Issue Type: Bug Components: storm-kafka-client Affects Versions: 2.0.0, 1.2.0 Reporter: Hugo Louro Priority: Critical
Currently the method {code:java} public void onPartitionsRevoked(Collection<TopicPartition> partitions) { {code} has the following condition {code:java} if (isAtLeastOnceProcessing() && initialized) { initialized = false; ... } {code} initialized should be set to false independently of the processing guarantee -- This message was sent by Atlassian JIRA (v6.4.14#64029)