You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@storm.apache.org by "Hugo Louro (JIRA)" <ji...@apache.org> on 2017/06/30 23:02:00 UTC

[jira] [Assigned] (STORM-2302) New Kafka spout doesn't support seek to given offset

     [ https://issues.apache.org/jira/browse/STORM-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hugo Louro reassigned STORM-2302:
---------------------------------

    Assignee: Hugo Louro

> 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
>            Assignee: Hugo Louro
>            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.
> Please refer attachment for further discussion happened over mail.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)