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)