diff --git a/clients/src/main/resources/common/message/ProduceRequest.json b/clients/src/main/resources/common/message/ProduceRequest.json index 2bec066fad55b..df83e7c172a6a 100644 --- a/clients/src/main/resources/common/message/ProduceRequest.json +++ b/clients/src/main/resources/common/message/ProduceRequest.json @@ -43,7 +43,7 @@ // AddPartitionsToTxn call. If V2 is disabled, the client can't use produce request version higher than 11 within // a transaction. "validVersions": "0-12", - "deprecatedVersions": "0-6", + "deprecatedVersions": "0-2", "flexibleVersions": "9+", "fields": [ { "name": "TransactionalId", "type": "string", "versions": "3+", "nullableVersions": "3+", "default": "null", "entityType": "transactionalId", diff --git a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala index 362796381c29b..586b8253a3d99 100644 --- a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala +++ b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala @@ -346,7 +346,7 @@ class SocketServerTest { assertTrue(requestsPerSec(requestVersion).getOrElse(0L) > 0, "RequestsPerSec should be higher than 0") assertEquals(None, deprecatedRequestsPerSec(requestVersion)) - requestVersion = 3 + requestVersion = 2 sendRequest(plainSocket, producerRequestBytes(requestVersion)) receivedReq = receiveRequest(server.dataPlaneRequestChannel) server.dataPlaneRequestChannel.sendNoOpResponse(receivedReq)