Pete Prokopowicz created STORM-1094:
---------------------------------------
Summary: kafka offset does not advance when deserializer yields no
object
Key: STORM-1094
URL: https://issues.apache.org/jira/browse/STORM-1094
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka
Affects Versions: 0.11.0
Reporter: Pete Prokopowicz
If a custom deserializer returns an empty list of objects as a result of
deserializing messages from kafka, the partition manager does not advance the
kafka offset, and the same message will continue to be deserialized and return
nothing. The code works if the deserializer returns null, but not if it
returns an empty list.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
