Skip to content

Commit 61debe7

Browse files
fix(metadata): try to fix MetadataImage refCount (#2089)
1 parent 9317209 commit 61debe7

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -581,6 +581,12 @@ class KRaftMetadataCache(
581581
val lock = imageLock
582582
lock.lock()
583583
try {
584+
newImage.retain()
585+
586+
if (_currentImage != MetadataImage.EMPTY) {
587+
_currentImage.release()
588+
}
589+
584590
_currentImage = newImage
585591
} finally {
586592
lock.unlock()

0 commit comments

Comments
 (0)