root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

KAFKA-19697: Fix unregistering connectorStatusMetrics NPE if tasks fail to start

This commit is contained in:
Fan Yang 2025-09-20 18:23:28 +08:00
parent 5919762009
commit fe4f3e4508
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
View File

@ -2394,6 +2394,10 @@ public final class Worker {
} }
protected synchronized void recordTaskRemoved(ConnectorTaskId connectorTaskId) { protected synchronized void recordTaskRemoved(ConnectorTaskId connectorTaskId) {
if (!connectorStatusMetrics.containsKey(connectorTaskId.connector())) {
return;
}
// Unregister connector task count metric if we remove the last task of the connector // Unregister connector task count metric if we remove the last task of the connector
if (tasks.keySet().stream().noneMatch(id -> id.connector().equals(connectorTaskId.connector()))) { if (tasks.keySet().stream().noneMatch(id -> id.connector().equals(connectorTaskId.connector()))) {
connectorStatusMetrics.get(connectorTaskId.connector()).close(); connectorStatusMetrics.get(connectorTaskId.connector()).close();