[
https://issues.apache.org/jira/browse/KAFKA-364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13295339#comment-13295339
]
Neha Narkhede commented on KAFKA-364:
-------------------------------------
I would like to throw in a couple use cases:
- Allow the new consumer to reset its offset to either the current
largest or smallest. This would be a great way to restart a process that
has fallen behind. The only way I know how to do this today, with the
high-level consumer, is to delete the ZK nodes manually and restart the
consumer.
- Allow the consumer to reset its offset to some arbitrary value, and
then write that offset into ZK. Kind of like the first case, but would
make rewinding/replays much easier.
Modularity (the ability to layer the ZK infrastructure on top of the simple
interface) would be great.
thanks,
Evan
> Consumer re-design
> ------------------
>
> Key: KAFKA-364
> URL: https://issues.apache.org/jira/browse/KAFKA-364
> Project: Kafka
> Issue Type: New Feature
> Reporter: Neha Narkhede
> Assignee: Neha Narkhede
>
> We've received quite a lot of feedback on the consumer side features over the
> past few months. Some of them are improvements to the current consumer design
> and some are simply new feature/API requests. I have attempted to write up
> the requirements that I've heard on this wiki -
> https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Client+Re-Design
> This would involve some significant changes to the consumer APIs, so we would
> like to collect feedback on the proposal from our community. Since the list
> of changes is not small, we would like to understand if some features are
> preferred over others, and more importantly, if some features are not
> required at all.
--
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
