@@ -204,11 +204,15 @@ async def _send(self, message: dict[str, object]) -> None:
             payload = ormsgpack.packb(message)
             # Log every outbound protocol event so the exact stream sent to the
             # vendor (start/text/flush/stop) can be reconstructed from the log.
+            # Only event names, sizes and counts are recorded: the utterance
+            # text stays out of vendor diagnostics and is logged under the
+            # transcript category instead.
             # Logged before the TTFB marker so measuring stays accurate.
             self.ten_env.log_info(
                 "vendor_send: "
                 f"event={message.get('event')}, bytes={len(payload)}, "
-                f"payload={message}",
+                f"keys={sorted(message.keys())}, "
+                f"text_chars={len(message.get('text') or '')}",
                 category=LOG_CATEGORY_VENDOR,
             )
             if message.get("event") == "text" and self.on_text_send is not None:
@@ -328,6 +332,9 @@ async def _reconnect_loop(self) -> None:
                 await self._reset_connection(notify=False)
                 await self._ensure_connection()
                 await self._start_session(request_id)
+                # _start_session() clears the finalization flag, so restore it:
+                # a further drop on this connection must still replay the stop.
+                self._session_stop_requested = stop_requested
                 for index, replay_text in enumerate(texts):
                     await self._send_text(
                         replay_text,
 
@@ -10,6 +10,7 @@
 
 import ormsgpack
 import pytest
+from ten_ai_base.const import LOG_CATEGORY_VENDOR
 
 from fish_audio_tts_python.config import FishAudioTTSConfig
 from fish_audio_tts_python.fish_audio_tts import FishAudioTTSClient
@@ -238,6 +239,36 @@ def test_flush_mode_is_not_forwarded_to_vendor_request() -> None:
     assert "flush_mode" not in request
 
 
+def test_vendor_send_logs_omit_user_text() -> None:
+    """Vendor diagnostics must not persist the utterance text."""
+
+    async def run() -> list[str]:
+        websocket = RecordingWebSocket()
+        ten_env = MagicMock()
+        with patch(
+            "fish_audio_tts_python.fish_audio_tts.connect",
+            return_value=FakeConnect(websocket),
+        ):
+            client = FishAudioTTSClient(_config(flush_mode="off"), ten_env)
+            async for _event in client.get(
+                "hello secret phrase",
+                request_id="req",
+                text_input_end=True,
+            ):
+                pass
+            await client.clean()
+        return [
+            call.args[0]
+            for call in ten_env.log_info.call_args_list
+            if call.kwargs.get("category") == LOG_CATEGORY_VENDOR
+        ]
+
+    messages = asyncio.run(run())
+    assert messages
+    for message in messages:
+        assert "secret" not in message
+
+
 # ================ on_text_send contract ================
 def test_client_invokes_on_text_send_before_each_text_payload() -> None:
     """The extension's TTFB anchor depends on this client contract.
 
@@ -119,8 +119,15 @@ async def run_test() -> None:
         assert len(span_id) == 16
         assert flags == "01"
 
-        ten_env.log_info.assert_called_once()
-        log_message = ten_env.log_info.call_args.args[0]
+        # The handshake and every outbound event are logged too, so pick the
+        # response-header entry instead of relying on call order.
+        header_logs = [
+            call.args[0]
+            for call in ten_env.log_info.call_args_list
+            if "WebSocket response headers" in call.args[0]
+        ]
+        assert len(header_logs) == 1
+        log_message = header_logs[0]
         assert "us-east-1" in log_message
         assert trace_id in log_message
         assert "x-request-id" in log_message