|
@ -1,4 +1,4 @@
|
|
|
package com.yihu.wlyy.analysis.scheduler;
|
|
|
package com.yihu.wlyy.analysis.listener;
|
|
|
|
|
|
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
|
|
import org.slf4j.Logger;
|
|
@ -13,7 +13,7 @@ import java.util.Optional;
|
|
|
* Created by Administrator on 2017/2/6.
|
|
|
*/
|
|
|
@Component
|
|
|
public class LabelDataScheduler {
|
|
|
public class LabelDataListener {
|
|
|
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
|
|
|
|
//@Scheduled(cron = "0 0/1 * * * ?") //每分钟执行一次
|