Commit 38477060 authored by 赵啸非's avatar 赵啸非

修改文件存储路径

parent 50110e70
...@@ -88,7 +88,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi ...@@ -88,7 +88,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
return new TopicPartitionInfo(Constant.UPLOAD_TOPIC + item.getDeviceCode(), null, exchangeName); return new TopicPartitionInfo(Constant.UPLOAD_TOPIC + item.getDeviceCode(), null, exchangeName);
} }
).collect(Collectors.toSet()); ).collect(Collectors.toSet());
mainConsumer.subscribe(topicPartitionInfoSet); //mainConsumer.subscribe(topicPartitionInfoSet);
topicPartitionInfoSet.stream().forEach(item -> { topicPartitionInfoSet.stream().forEach(item -> {
log.info("消费线程订阅topic:{}", item.getTopic()); log.info("消费线程订阅topic:{}", item.getTopic());
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment