Sachin Pasalkar created STORM-2302:
--------------------------------------
Summary: New Kafka spout doesn't support seek to given offset
Key: STORM-2302
URL: https://issues.apache.org/jira/browse/STORM-2302
Project: Apache Storm
Issue Type: Improvement
Components: storm-kafka-client
Affects Versions: 1.x
Reporter: Sachin Pasalkar
Priority: Minor
Attachments: Discussion
I was looking at code of current KafkaTridentSpoutEmitter & KafkaSpout class.
Can we add functionality based on user provided offset to start from particular
offset? This would be useful incase user wants to reprocess particular data
set. Another example user has changed the group id & aware where old offset
committed & he wants to start processing from same position.
Does this make sense? OR its explicit that it will not be supported?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
