[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14069525#comment-14069525 ] Jay Kreps commented on KAFKA-1330: -- Updated reviewboard https://reviews.apache.org/r/23442/ against branch trunk 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, KAFKA-1330_2014-07-21_16:44:23.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)
[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059904#comment-14059904 ] Jay Kreps commented on KAFKA-1330: -- Created reviewboard https://reviews.apache.org/r/23442/ against branch trunk 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 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)
[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059905#comment-14059905 ] Jay Kreps commented on KAFKA-1330: -- Hey [~nmarasoi], sorry had actually been working on this for the last week...I should have assigned it to myself. 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)
[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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)
[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059221#comment-14059221 ] nicu marasoiu commented on KAFKA-1330: -- Hi, If I want to take this, how much time to get up to speed do I have? Which are the documents to read? I have kafka experience and scala courses, I will try to jump in 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 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)
