Skip to content

毛树良 / VVAS-DataCenter-DBWriter

Go to a project
Commit 2b99e86c by 毛树良
Options

[chg]：全天分析后统计数据优化并发线程数和队列容量

1 parent dd9c30c2
Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
src/main/java/com/viontech/keliu/consumer/MallDataStatisticsConsumer.java
...@@ -33,7 +33,7 @@ public class MallDataStatisticsConsumer { ...@@ -33,7 +33,7 @@ public class MallDataStatisticsConsumer {
@Value("${vion.consumer.storeDataStatistics.reidUrl:}") @Value("${vion.consumer.storeDataStatistics.reidUrl:}")
private String reidUrl; private String reidUrl;
private ExecutorService executorService = ThreadUtil.newFixedExecutor(10, 2000, "dataStatistics-", true); private ExecutorService executorService = ThreadUtil.newFixedExecutor(15, 5000, "dataStatistics-", true);
@KafkaListener(topics = KafkaConstants.STORE_DATA_STATISTICS_TOPIC @KafkaListener(topics = KafkaConstants.STORE_DATA_STATISTICS_TOPIC
, autoStartup = "${vion.consumer.storeDataStatistics.autoStartup:false}" , autoStartup = "${vion.consumer.storeDataStatistics.autoStartup:false}"
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!