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