diff --git a/src/service/strategy/market_trade_listener.go b/src/service/strategy/market_trade_listener.go
index 8b81a5c..07ac451 100644
--- a/src/service/strategy/market_trade_listener.go
+++ b/src/service/strategy/market_trade_listener.go
@@ -72,7 +72,7 @@ func (m *MarketTradeListener) ListenAll() {
 	}(&predictMap)
 
 	// Consumer count for kline channel
-	klineConsumerCount := 4
+	klineConsumerCount := 8
 
 	for i := 0; i < klineConsumerCount; i++ {
 		go func() {