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 8255888fd76..5051890b182 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 class InitProducerIdRequest extends AbstractRequest { .setErrorCode(Errors.forException(e).code()) .setProducerId(RecordBatch.NO_PRODUCER_ID) .setProducerEpoch(RecordBatch.NO_PRODUCER_EPOCH) - .setThrottleTimeMs(0); + .setThrottleTimeMs(throttleTimeMs); return new InitProducerIdResponse(response); }