Skip to content

毛树良 / VVAS-DataCenter-DBWriter

Go to a project
Commit c8f1cb7b by wenshuaiying
Options

解决topic错误

1 parent 42638e15
Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
src/main/java/com/viontech/keliu/consumer/MallZoneMinuteCountDataConsumer.java
......@@ -37,7 +37,7 @@ public class MallZoneMinuteCountDataConsumer {
@Resource
private SpeedStatService speedStatService;
@KafkaListener(topics = KafkaConstants.MALL_ZONE_MINUTE_COUNT_DATA_TOPIC
@KafkaListener(topics = KafkaConstants.STORE_ZONE_MINUTE_COUNT_DATA_TOPIC
, autoStartup = "${vion.consumer.mallZoneMinuteCount.autoStartup:false}"
, groupId = "MallZoneMinuteCountToDb"
, concurrency = "${vion.consumer.mallZoneMinuteCount.concurrency:1}")
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!