Kyle Nusbaum created STORM-2180:
-----------------------------------
Summary: KafkaSpout ack() should handle re-balance
Key: STORM-2180
URL: https://issues.apache.org/jira/browse/STORM-2180
Project: Apache Storm
Issue Type: Bug
Reporter: Kyle Nusbaum
Assignee: Kyle Nusbaum
Currently the kafkaSpout ack() routine doesn't handle if a re-balance happened
and an ack for a partition it no longer handles get sent back to it. It will
throw a null pointer exception. We should check to make sure that partition
exists before calling .add.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
