Return-Path: X-Original-To: apmail-incubator-kafka-dev-archive@minotaur.apache.org Delivered-To: apmail-incubator-kafka-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 24BE59B9C for ; Fri, 4 Nov 2011 11:09:22 +0000 (UTC) Received: (qmail 41795 invoked by uid 500); 4 Nov 2011 11:09:22 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 41773 invoked by uid 500); 4 Nov 2011 11:09:21 -0000 Mailing-List: contact kafka-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: kafka-dev@incubator.apache.org Delivered-To: mailing list kafka-dev@incubator.apache.org Received: (qmail 41765 invoked by uid 99); 4 Nov 2011 11:09:21 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Nov 2011 11:09:21 +0000 X-ASF-Spam-Status: No, hits=-2001.2 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Nov 2011 11:09:20 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 1C24E3310FF for ; Fri, 4 Nov 2011 11:09:00 +0000 (UTC) Date: Fri, 4 Nov 2011 11:09:00 +0000 (UTC) From: "Indebir Singh Pall (Commented) (JIRA)" To: kafka-dev@incubator.apache.org Message-ID: <1347240342.585.1320404940116.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <181252248.9461.1319477432367.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Commented] (KAFKA-168) Support locality in consumer partition assignment algorithm MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13143915#comment-13143915 ] Indebir Singh Pall commented on KAFKA-168: ------------------------------------------ Jay i agree with you that getting the hostname programatically will abstract out things. I'll do some research. > Support locality in consumer partition assignment algorithm > ----------------------------------------------------------- > > Key: KAFKA-168 > URL: https://issues.apache.org/jira/browse/KAFKA-168 > Project: Kafka > Issue Type: New Feature > Components: core > Reporter: Jay Kreps > > There are some use-cases where it makes sense to co-locate brokers and consumer processes. In this case it would be nice to optimize the assignment of partitions to consumers so that the consumer preferentially consumes from the broker with which it is co-located. > If we are going to do KAFKA-167, moving the assignment to the broker, it would make sense to do that first so we only have to change the logic in one place. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira