|
@@ -61,7 +61,7 @@ public class EtlMQConsumer {
|
|
|
private String topic;
|
|
|
@Value("${rocketmq.crawler.etl.groupid:}")
|
|
|
private String groupId;
|
|
|
- @Value("${consumer.thread.size:10}")
|
|
|
+ @Value("${consumer.thread.size:32}")
|
|
|
private Integer threadSize;
|
|
|
|
|
|
private MQConsumer consumer;
|