kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward Capriolo (Commented) (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-232) ConsumerConnector has no access to "getOffsetsBefore"
Date Wed, 04 Jan 2012 03:06:41 GMT

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

Edward Capriolo commented on KAFKA-232:

Sure. I am using Kafka to build aggregations of logs. These aggregations are going to be minutely.
I want to record clientid and my log position externally. If my consumer goes down 30 seconds
into the minute I want to replay the entire minute over. I might also want to bring this client
up at position x on another node.
> 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


View raw message