Skip to content

毛树良 / VVAS-DataCenter-DBWriter

Go to a project
Commit 45d59e2c by wenshuaiying
Options

替换topic的名字及配置key

1 parent 4f7cf1fb
Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
src/main/java/com/viontech/keliu/consumer/MallGateMinuteCountDataConsumer.java
...@@ -39,7 +39,7 @@ public class MallGateMinuteCountDataConsumer { ...@@ -39,7 +39,7 @@ public class MallGateMinuteCountDataConsumer {
@KafkaListener(topics = KafkaConstants.STORE_GATE_MINUTE_COUNT_DATA_TOPIC @KafkaListener(topics = KafkaConstants.STORE_GATE_MINUTE_COUNT_DATA_TOPIC
, autoStartup = "${vion.consumer.storeGateMinuteCount.autoStartup:false}" , autoStartup = "${vion.consumer.storeGateMinuteCount.autoStartup:false}"
, groupId = "MallGateMinuteCountToDb" , groupId = "StoreGateMinuteCountToDb"
, concurrency = "${vion.consumer.storeGateMinuteCount.concurrency:1}") , concurrency = "${vion.consumer.storeGateMinuteCount.concurrency:1}")
public void consumerMallGateMinuteCount(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) { public void consumerMallGateMinuteCount(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
if (CollectionUtils.isEmpty(recordList)) { if (CollectionUtils.isEmpty(recordList)) {
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!