diff --git a/bumble/host.py b/bumble/host.py
index 8fc005f2..f3e63189 100644
--- a/bumble/host.py
+++ b/bumble/host.py
@@ -17,6 +17,7 @@
 # -----------------------------------------------------------------------------
 from __future__ import annotations
 
+import time
 import asyncio
 import collections
 import dataclasses
@@ -256,6 +257,8 @@ class Host(utils.EventEmitter):
     long_term_key_provider: Callable[[int, bytes, int], Awaitable[bytes | None]] | None
     link_key_provider: Callable[[hci.Address], Awaitable[bytes | None]] | None
 
+    _ACL_STALE_TIMEOUT_S: float = 0.500  # 500 ms
+
     def __init__(
         self,
         controller_source: TransportSource | None = None,
@@ -293,6 +296,9 @@ def __init__(
         self.link_key_provider = None
         self.pairing_io_capability_provider = None  # Classic only
         self.snooper: Snooper | None = None
+        self._pending_acl: dict[int, list[tuple[float, hci.HCI_AclDataPacket]]] = {}
+        self._drain_acl_buffer_task: asyncio.Task[None] | None = None
+        self.on("le_connection", self._drain_buffered_acl)
 
         # Connect to the source and sink if specified
         if controller_source:
@@ -1034,6 +1040,13 @@ def on_hci_acl_data_packet(self, packet: hci.HCI_AclDataPacket) -> None:
             connection.on_hci_acl_data_packet(packet)
             return
 
+        logger.warning(
+            f"ACL data arrived before Connection Complete for handle {packet.connection_handle} — buffering"
+        )
+        self._pending_acl.setdefault(packet.connection_handle, []).append(
+            (time.monotonic(), packet)
+        )
+
         # WORKAROUND: Some controllers (e.g. Intel BE200) send ISO data wrapped in ACL packets
         # using the CIS handle.
         is_cis = packet.connection_handle in self.cis_links
@@ -1120,6 +1133,19 @@ def on_hci_iso_data_packet(self, packet: hci.HCI_IsoDataPacket) -> None:
     def on_l2cap_pdu(self, connection: Connection, cid: int, pdu: bytes) -> None:
         self.emit('l2cap_pdu', connection.handle, cid, pdu)
 
+    async def _drain_buffered_acl(
+        self, handle: int, *_connection_parameters: Any
+    ) -> None:
+        """Replay all buffered ACL packet"""
+        queued = self._pending_acl.pop(handle, [])
+        if not queued:
+            return
+        now = time.monotonic()
+        logger.info(f"Replaying buffered ACL packets for handle: {handle}")
+        for ts, packet in queued:
+            if (now - ts) <= self._ACL_STALE_TIMEOUT_S:
+                self.on_hci_acl_data_packet(packet)
+
     def on_command_processed(
         self, event: hci.HCI_Command_Complete_Event | hci.HCI_Command_Status_Event
     ):
diff --git a/tests/host_test.py b/tests/host_test.py
index b7280443..5dc81812 100644
--- a/tests/host_test.py
+++ b/tests/host_test.py
@@ -88,6 +88,28 @@ async def test_reset_enables_number_of_completed_packets_event() -> None:
     assert host.le_acl_packet_queue.max_in_flight == 3
 
 
+# -----------------------------------------------------------------------------
+@pytest.mark.asyncio
+async def test_le_connection_replays_buffered_acl() -> None:
+    host = Host()
+    connection_handle = 123
+    packet = HCI_AclDataPacket(
+        connection_handle=connection_handle,
+        pb_flag=0,
+        bc_flag=0,
+        data_total_length=0,
+        data=b'',
+    )
+    host.on_hci_acl_data_packet(packet)
+
+    connection = unittest.mock.Mock()
+    host.connections[connection_handle] = connection
+    host.emit('le_connection', connection_handle, None, None, None, None, 0, 0, 0)
+    await asyncio.sleep(0)
+
+    connection.on_hci_acl_data_packet.assert_called_once_with(packet)
+
+
 # -----------------------------------------------------------------------------
 def test_data_packet_queue():
     controller = unittest.mock.Mock()