diff --git a/application/src/test/java/org/thingsboard/server/transport/mqtt/mqttv3/rpc/MqttClientSideRpcIntegrationTest.java b/application/src/test/java/org/thingsboard/server/transport/mqtt/mqttv3/rpc/MqttClientSideRpcIntegrationTest.java
index 2a700e484d..6489054ba9 100644
--- a/application/src/test/java/org/thingsboard/server/transport/mqtt/mqttv3/rpc/MqttClientSideRpcIntegrationTest.java
+++ b/application/src/test/java/org/thingsboard/server/transport/mqtt/mqttv3/rpc/MqttClientSideRpcIntegrationTest.java
@@ -68,7 +68,6 @@ public class MqttClientSideRpcIntegrationTest extends AbstractMqttIntegrationTes
         expectedLimits.setRateLimits(deviceLimits);
         expectedLimits.setMaxPayloadSize(maxPayloadSize);
         expectedLimits.setMaxInflightMessages(maxInflightMessages);
-        expectedLimits.setPayloadType(TransportPayloadType.JSON);
 
         MqttTestConfigProperties configProperties = MqttTestConfigProperties.builder()
                 .deviceName("Test Get Service Configuration")
@@ -122,7 +121,6 @@ public class MqttClientSideRpcIntegrationTest extends AbstractMqttIntegrationTes
         expectedLimits.setRateLimits(gatewayDeviceLimits);
         expectedLimits.setMaxPayloadSize(maxPayloadSize);
         expectedLimits.setMaxInflightMessages(maxInflightMessages);
-        expectedLimits.setPayloadType(TransportPayloadType.JSON);
 
         MqttTestConfigProperties configProperties = MqttTestConfigProperties.builder()
                 .gatewayName("Test Get Service Configuration Gateway")
diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
index 823e558370..4212386410 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@@ -1364,7 +1364,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
         }
         sessionLimits.setMaxPayloadSize(context.getMaxPayloadSize());
         sessionLimits.setMaxInflightMessages(context.getMessageQueueSizePerDeviceLimit());
-        sessionLimits.setPayloadType(deviceSessionCtx.getPayloadType());
 
         ack(ctx, msgId, MqttReasonCodes.PubAck.SUCCESS);
 
diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/limits/SessionLimits.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/limits/SessionLimits.java
index 7651d27386..b607bfadfc 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/limits/SessionLimits.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/limits/SessionLimits.java
@@ -23,7 +23,6 @@ public class SessionLimits {
 
     private int maxPayloadSize;
     private int maxInflightMessages;
-    private TransportPayloadType payloadType;
     private SessionRateLimits rateLimits;
 
     public record SessionRateLimits(String messages, String telemetryMessages, String telemetryDataPoints) {}