diff --git a/src/pysparkplug/_client.py b/src/pysparkplug/_client.py
index ca8222a..8a75204 100644
--- a/src/pysparkplug/_client.py
+++ b/src/pysparkplug/_client.py
@@ -57,7 +57,7 @@ def __init__(
     ) -> None:
         self._client = paho_mqtt.Client(
             client_id=client_id,  # type: ignore[reportArgumentType]
-            clean_session=True,
+            clean_session=None if MQTTProtocol.MQTT_V5 == protocol else True,
             protocol=protocol,
             transport=(
                 Transport.WS