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

Jay Kreps commented on KAFKA-1330:
----------------------------------

Guys, I posted a very rough draft that implements "simple consumer" 
functionality. I think implementing offset maintainence on top of this will be 
pretty easy and can be done once we have those new request defn's done. I'd 
like to start getting these changes in even though they aren't done to avoid 
keeping large patches against trunk. Specifically what I am hoping is that we 
can do a detailed review on the changes to common code, esp with respect to 
NetworkClient and be a bit lax on KafkaConsumer until we get something more 
complete.

> Implement subscribe(TopicPartition...partitions) in the new consumer
> --------------------------------------------------------------------
>
>                 Key: KAFKA-1330
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1330
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: consumer
>    Affects Versions: 0.9.0
>            Reporter: Neha Narkhede
>            Assignee: Jay Kreps
>         Attachments: KAFKA-1330.patch
>
>
> This involves adding basic fetch functionality (equivalent to SimpleConsumer) 
> to the new consumer. Effectively implementing 
> subscribe(TopicPartition...partitions) and 
> unsubscribe(TopicPartition...partitions).



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Reply via email to