Details
-
Bug
-
Status: Done
-
Major
-
Resolution: Done
-
None
-
None
Description
Due to a bug in the storm-kafka-client in 1.1.0, offsets are not committed in the pcap topology. This can be worked around by ensuring that ack is called after nextTuple() rather than during nextTuple(). This is ONLY a problem in spout-only topologies (which self-ack).
Attachments
Issue Links
- links to