Chris Riccomini created SAMZA-140:
-------------------------------------
Summary: 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
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)