[ 
https://issues.apache.org/jira/browse/KAFKA-232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13180841#comment-13180841
 ] 

Jun Rao commented on KAFKA-232:
-------------------------------

Do you think you can add meta data in the message itself so that you know 
whether the consumed data has moved to the next minute? If so, you can turn off 
auto commit and call commitOffset() directly.
                
> ConsumerConnector has no access to "getOffsetsBefore" 
> ------------------------------------------------------
>
>                 Key: KAFKA-232
>                 URL: https://issues.apache.org/jira/browse/KAFKA-232
>             Project: Kafka
>          Issue Type: New Feature
>            Reporter: Edward Capriolo
>            Priority: Minor
>
> kafka.javaapi.SimpleConsumer has "getOffsetsBefore". I would like this 
> ability in KafkaMessageStream or in ConsumerConnector. In this way clients 
> can access their current position.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to