diff --git a/fooltrader/datasource/eos.py b/fooltrader/datasource/eos.py
index 3daac37..35f6507 100644
--- a/fooltrader/datasource/eos.py
+++ b/fooltrader/datasource/eos.py
@@ -79,6 +79,8 @@ def eos_ram_to_kafka():
 
         logger.info("start_date:{},end_date:{}".format(start_date, end_date))
 
+        latest_timestamp = end_date
+
         for item in ram_trade.find(condition):
             tick = to_tick(item)