From f4e00e9cf082525d7c1d9fa62c23f2400b62bb1d Mon Sep 17 00:00:00 2001 From: Lan Ding Date: Thu, 25 Sep 2025 23:52:46 +0800 Subject: [PATCH] MINOR: Remove unnecessary check in ReplicaManager (#20588) `setTopics` is executed at before, so the check is unnecessary. Reviewers: Ken Huang , Chia-Ping Tsai --- core/src/main/scala/kafka/server/ReplicaManager.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 070b3e544a6..10b41b88bd0 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -1261,11 +1261,11 @@ class ReplicaManager(val config: KafkaConfig, } val describeLogDirsResult = new DescribeLogDirsResponseData.DescribeLogDirsResult() - .setLogDir(absolutePath).setTopics(topicInfos) + .setLogDir(absolutePath) + .setTopics(topicInfos) .setErrorCode(Errors.NONE.code) - .setTotalBytes(totalBytes).setUsableBytes(usableBytes) - if (!topicInfos.isEmpty) - describeLogDirsResult.setTopics(topicInfos) + .setTotalBytes(totalBytes) + .setUsableBytes(usableBytes) describeLogDirsResult } catch {