diff --git a/piker/brokers/kucoin.py b/piker/brokers/kucoin.py
index 3cd4b1ee..98bb32a8 100644
--- a/piker/brokers/kucoin.py
+++ b/piker/brokers/kucoin.py
@@ -586,13 +586,13 @@ async def stream_messages(ws: NoBsWs, sym: str) -> AsyncGenerator[NoBsWs, dict]:
                     yield 'trade', {
                         'symbol': sym,
                         'last': trade_data.price,
-                        'brokerd_ts': trade_data.time,
+                        'brokerd_ts': trade_data_ts,
                         'ticks': [
                             {
                                 'type': 'trade',
                                 'price': float(trade_data.price),
                                 'size': float(trade_data.size),
-                                'broker_ts': trade_data.time,
+                                'broker_ts': trade_data_ts,
                             }
                         ],
                     }