diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/DiagnosticUtils.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/DiagnosticUtils.java
index 37eea1a3..0f350c07 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/DiagnosticUtils.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/DiagnosticUtils.java
@@ -35,7 +35,7 @@ public class DiagnosticUtils {
     public static void takeDelayedDeliveryActionIfRequired(String resourceIdentifier, Instant enqueueTimestamp, Logger log) {
         final long durationBetweenEnqueueAndAckInMillis = Duration
                 .between(enqueueTimestamp, Instant.now()).toMillis();
-        if (durationBetweenEnqueueAndAckInMillis > MAX_TIME_BETWEEN_REQUEST_RESPONSE / 3) {
+        if (durationBetweenEnqueueAndAckInMillis > 11000) {
             // The above condition logs the warn msg if the delivery time exceeds 11 seconds.
             log.warn(
                     "{}: Record delivery time to shard consumer is high at {} millis. Check the ExecutorStateEvent logs"