[ 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)