You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Jakob Homan (JIRA)" <ji...@apache.org> on 2014/01/10 00:33:51 UTC

[jira] [Commented] (SAMZA-127) Only reading one topic/partition per-broker in KafkaSystemConsumer

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

Jakob Homan commented on SAMZA-127:
-----------------------------------

+1


> Only reading one topic/partition per-broker in KafkaSystemConsumer
> ------------------------------------------------------------------
>
>                 Key: SAMZA-127
>                 URL: https://issues.apache.org/jira/browse/SAMZA-127
>             Project: Samza
>          Issue Type: Bug
>          Components: kafka
>    Affects Versions: 0.6.0
>            Reporter: Chris Riccomini
>            Assignee: Chris Riccomini
>         Attachments: SAMZA-127.0.patch
>
>
> As part of SAMZA-21, we messed with KafkaSystemConsumer.refreshBrokers. In the process of doing so, we accidentally stopped updating BrokerProxy with all topic/partitions that it should consume after we add the first one. As a result, each BrokerProxy only consumes a single topic/partition pair.



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)