[
https://issues.apache.org/jira/browse/SAMZA-140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini updated SAMZA-140:
----------------------------------
Attachment: SAMZA-140.0.patch
Attaching patch. RB at:
https://reviews.apache.org/r/17912/
> BrokerProxy.removeTopicPartition is never called
> ------------------------------------------------
>
> Key: SAMZA-140
> URL: https://issues.apache.org/jira/browse/SAMZA-140
> Project: Samza
> Issue Type: Bug
> Components: kafka
> Affects Versions: 0.6.0
> Reporter: Chris Riccomini
> Assignee: Chris Riccomini
> Attachments: SAMZA-140.0.patch
>
>
> It appears that BrokerProxy.removeTopicPartition is never called. Instead,
> we're using nextOffsets.remove(tp) directly in the code.
> This is wrong because it never updates the metrics.topicPartitions gauge,
> which means that the topic/partition count for brokers is wrong.
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
