[ https://issues.apache.org/jira/browse/STORM-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated STORM-2787: ---------------------------------- Labels: pull-request-available (was: ) > 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 > Assignee: Hugo Louro > Priority: Critical > Labels: pull-request-available > > 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)