diff --git a/homeassistant/components/nest/manifest.json b/homeassistant/components/nest/manifest.json
index 11a464dbaf1..507711c73ff 100644
--- a/homeassistant/components/nest/manifest.json
+++ b/homeassistant/components/nest/manifest.json
@@ -4,7 +4,7 @@
   "config_flow": true,
   "dependencies": ["ffmpeg", "http", "media_source"],
   "documentation": "https://www.home-assistant.io/integrations/nest",
-  "requirements": ["python-nest==4.1.0", "google-nest-sdm==0.4.5"],
+  "requirements": ["python-nest==4.1.0", "google-nest-sdm==0.4.6"],
   "codeowners": ["@allenporter"],
   "quality_scale": "platinum",
   "dhcp": [
diff --git a/requirements_all.txt b/requirements_all.txt
index 5d09fdacd27..946a31d64f9 100644
--- a/requirements_all.txt
+++ b/requirements_all.txt
@@ -747,7 +747,7 @@ google-cloud-pubsub==2.1.0
 google-cloud-texttospeech==0.4.0
 
 # homeassistant.components.nest
-google-nest-sdm==0.4.5
+google-nest-sdm==0.4.6
 
 # homeassistant.components.google_travel_time
 googlemaps==2.5.1
diff --git a/requirements_test_all.txt b/requirements_test_all.txt
index 7c368e7b3fd..926e5435048 100644
--- a/requirements_test_all.txt
+++ b/requirements_test_all.txt
@@ -470,7 +470,7 @@ google-api-python-client==1.6.4
 google-cloud-pubsub==2.1.0
 
 # homeassistant.components.nest
-google-nest-sdm==0.4.5
+google-nest-sdm==0.4.6
 
 # homeassistant.components.google_travel_time
 googlemaps==2.5.1
diff --git a/tests/components/nest/common.py b/tests/components/nest/common.py
index 35183a441a5..0f1d47c687e 100644
--- a/tests/components/nest/common.py
+++ b/tests/components/nest/common.py
@@ -62,7 +62,7 @@ class FakeSubscriber(GoogleNestSubscriber):
 
     def set_update_callback(self, callback: Callable[[EventMessage], Awaitable[None]]):
         """Capture the callback set by Home Assistant."""
-        self._callback = callback
+        self._device_manager.set_update_callback(callback)
 
     async def create_subscription(self):
         """Create the subscription."""
@@ -93,7 +93,6 @@ class FakeSubscriber(GoogleNestSubscriber):
         """Simulate a received pubsub message, invoked by tests."""
         # Update device state, then invoke HomeAssistant to refresh
         await self._device_manager.async_handle_event(event_message)
-        await self._callback(event_message)
 
 
 async def async_setup_sdm_platform(
diff --git a/tests/components/nest/test_events.py b/tests/components/nest/test_events.py
index a2f5c21fdac..4767fd815d2 100644
--- a/tests/components/nest/test_events.py
+++ b/tests/components/nest/test_events.py
@@ -4,6 +4,8 @@ These tests fake out the subscriber/devicemanager, and are not using a real
 pubsub subscriber.
 """
 
+import datetime
+
 from google_nest_sdm.device import Device
 from google_nest_sdm.event import EventMessage
 
@@ -298,3 +300,74 @@ async def test_event_message_without_device_event(hass):
     await hass.async_block_till_done()
 
     assert len(events) == 0
+
+
+async def test_doorbell_event_thread(hass):
+    """Test a series of pubsub messages in the same thread."""
+    events = async_capture_events(hass, NEST_EVENT)
+    subscriber = await async_setup_devices(
+        hass,
+        "sdm.devices.types.DOORBELL",
+        traits={
+            "sdm.devices.traits.Info": {
+                "customName": "Front",
+            },
+            "sdm.devices.traits.CameraLiveStream": {},
+            "sdm.devices.traits.CameraClipPreview": {},
+            "sdm.devices.traits.CameraPerson": {},
+        },
+    )
+    registry = er.async_get(hass)
+    entry = registry.async_get("camera.front")
+    assert entry is not None
+
+    event_message_data = {
+        "eventId": "some-event-id-ignored",
+        "resourceUpdate": {
+            "name": DEVICE_ID,
+            "events": {
+                "sdm.devices.events.CameraMotion.Motion": {
+                    "eventSessionId": EVENT_SESSION_ID,
+                    "eventId": "n:1",
+                },
+                "sdm.devices.events.CameraClipPreview.ClipPreview": {
+                    "eventSessionId": EVENT_SESSION_ID,
+                    "previewUrl": "image-url-1",
+                },
+            },
+        },
+        "eventThreadId": "CjY5Y3VKaTZwR3o4Y19YbTVfMF...",
+        "resourcegroup": [DEVICE_ID],
+    }
+
+    # Publish message #1 that starts the event thread
+    timestamp1 = utcnow()
+    message_data_1 = event_message_data.copy()
+    message_data_1.update(
+        {
+            "timestamp": timestamp1.isoformat(timespec="seconds"),
+            "eventThreadState": "STARTED",
+        }
+    )
+    await subscriber.async_receive_event(EventMessage(message_data_1, auth=None))
+
+    # Publish message #1 that sends a no-op update to end the event thread
+    timestamp2 = timestamp1 + datetime.timedelta(seconds=1)
+    message_data_2 = event_message_data.copy()
+    message_data_2.update(
+        {
+            "timestamp": timestamp2.isoformat(timespec="seconds"),
+            "eventThreadState": "ENDED",
+        }
+    )
+    await subscriber.async_receive_event(EventMessage(message_data_2, auth=None))
+    await hass.async_block_till_done()
+
+    # The event is only published once
+    assert len(events) == 1
+    assert events[0].data == {
+        "device_id": entry.device_id,
+        "type": "camera_motion",
+        "timestamp": timestamp1.replace(microsecond=0),
+        "nest_event_id": EVENT_SESSION_ID,
+    }