From 6d23e9a16e5e7dd29365dcf907fc1e07f5217032 Mon Sep 17 00:00:00 2001 From: lambdaliu Date: Thu, 28 Feb 2019 19:28:43 +0800 Subject: [PATCH] avoid quota check when replica is in sync --- core/src/main/scala/kafka/server/ReplicaFetcherThread.scala | 2 +- core/src/main/scala/kafka/server/ReplicaManager.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala index 64ae71e35f0f0..d1659c85525c2 100644 --- a/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala +++ b/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala @@ -328,7 +328,7 @@ class ReplicaFetcherThread(name: String, */ private def shouldFollowerThrottle(quota: ReplicaQuota, topicPartition: TopicPartition): Boolean = { val isReplicaInSync = fetcherLagStats.isReplicaInSync(topicPartition) - quota.isThrottled(topicPartition) && quota.isQuotaExceeded && !isReplicaInSync + !isReplicaInSync && quota.isThrottled(topicPartition) && quota.isQuotaExceeded } } diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 6142c24943d51..3e7d7bb5e1efa 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -1007,7 +1007,7 @@ class ReplicaManager(val config: KafkaConfig, val isReplicaInSync = nonOfflinePartition(topicPartition).exists { partition => partition.getReplica(replicaId).exists(partition.inSyncReplicas.contains) } - quota.isThrottled(topicPartition) && quota.isQuotaExceeded && !isReplicaInSync + !isReplicaInSync && quota.isThrottled(topicPartition) && quota.isQuotaExceeded } def getLogConfig(topicPartition: TopicPartition): Option[LogConfig] = localReplica(topicPartition).flatMap(_.log.map(_.config))