diff --git a/pkg/bbgo/session.go b/pkg/bbgo/session.go
index ebc1413d3..ef04be202 100644
--- a/pkg/bbgo/session.go
+++ b/pkg/bbgo/session.go
@@ -244,7 +244,7 @@ func (session *ExchangeSession) Init(ctx context.Context, environ *Environment)
 	}
 
 	session.Stream.OnKLineClosed(func(kline types.KLine) {
-		log.Infof("kline closed: %+v", kline)
+		log.WithField("marketData", "kline").Infof("kline closed: %+v", kline)
 	})
 
 	// update last prices