[
https://issues.apache.org/jira/browse/SAMZA-127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini resolved SAMZA-127.
-----------------------------------
Resolution: Fixed
Merged and committed.
> 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)
