新增kafka发送,时间乱序
|
---|
|
pom.xml |
---|
src/main/java/com/casic/config/KafkaTopicConfig.java 0 → 100644 |
---|
src/main/java/com/casic/config/task/TaskConfigurer.java |
---|
src/main/java/com/casic/dao/DayDataDao.java |
---|
src/main/java/com/casic/entity/StandardData.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/Producer.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/constant/TopicConstant.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/util/KafkaProperties.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/util/KafkaUtils.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/util/LoginUtil.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/util/SimplePartitioner.java 0 → 100644 |
---|
src/main/java/com/casic/kafka/util/SpringUtils.java 0 → 100644 |
---|
src/main/java/com/casic/service/impl/DayDataProvider.java |
---|
src/main/resources/config/application.yml |
---|
src/main/resources/mapper/DayDataDao.xml |
---|