[
https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204354#comment-14204354
]
Jay Kreps commented on KAFKA-1760:
----------------------------------
I uploaded a very rough draft for this. It implements basically
- simple consumer for a specified topic/partition
- join group to use the new co-ordinator (implemented a server-side stub for
this)
- commit offsets (async or sync)
- seek (including seekToBeginning and seekToEnd)
- auto offset reset
Limitations
- Not executing the pre and post rebalance callbacks
- No real error handling
- Need to failure detect a controller that doesn't answer heartbeats
- Probably still pretty buggy
- Integration tests only cover basic cases
- Code is still very ugly
Error cases that need to be implemented and tested:
- Controller failure
- Commit retries
- Basically other cases where a specially timed failure can interrupt the
non-fetch requests (e.g. fetch offsets, commit offsets, list offsets, etc)
> Implement new consumer client
> -----------------------------
>
> Key: KAFKA-1760
> URL: https://issues.apache.org/jira/browse/KAFKA-1760
> Project: Kafka
> Issue Type: Sub-task
> Components: consumer
> Reporter: Jay Kreps
> Assignee: Jay Kreps
> Attachments: KAFKA-1760.patch
>
>
> Implement a consumer client.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
