From e93c1184ecb5dc586bfc6cd4e3ea7cc1579c0528 Mon Sep 17 00:00:00 2001
From: rreddy-22 <rreddy@confluent.io>
Date: Fri, 23 May 2025 15:43:47 -0700
Subject: [PATCH] throttle time shouldn't be zero
---
.../org/apache/kafka/common/requests/InitProducerIdRequest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java
index 8255888fd76dc..5051890b1829d 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java
@@ -62,7 +62,7 @@ public AbstractResponse getErrorResponse(int throttleTimeMs, Throwable e) {
.setErrorCode(Errors.forException(e).code())
.setProducerId(RecordBatch.NO_PRODUCER_ID)
.setProducerEpoch(RecordBatch.NO_PRODUCER_EPOCH)
- .setThrottleTimeMs(0);
+ .setThrottleTimeMs(throttleTimeMs);
return new InitProducerIdResponse(response);
}