Akhilesh Chaganti created KAFKA-14170:
-----------------------------------------
Summary: KRaft Controller: Possible NPE when we remove topics with
any offline partitions in the cluster
Key: KAFKA-14170
URL: https://issues.apache.org/jira/browse/KAFKA-14170
Project: Kafka
Issue Type: Bug
Components: kraft
Affects Versions: 3.3
Reporter: Akhilesh Chaganti
Assignee: Akhilesh Chaganti
Fix For: 3.3
When we remove a topic, it goes through the following function in KRaft
Controller replay method for RemoveTopicRecord:
{code:java}
void removeTopicEntryForBroker(Uuid topicId, int brokerId) {
Map<Uuid, int[]> topicMap = isrMembers.get(brokerId);
if (topicMap != null) {
if (brokerId == NO_LEADER) {
offlinePartitionCount.set(offlinePartitionCount.get() -
topicMap.get(topicId).length);
}
topicMap.remove(topicId);
}
} {code}
If the broker has any offline partitions but doesn't have offline partitions
for the topic we're deleting, the above code will run into NPE because we
directly access the `topicMap.get(topicId).length`
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
